For low volume MySQL sources, it is possible that the log becomes stale due to a lack of change events. As a result, events may not be captured by the Connector.
To address this, the heartbeat process involves writing an insert or update to a heartbeat table every 1 second to generate a change event.
CREATE TABLE heartbeat (
id INT AUTO_INCREMENT PRIMARY KEY,
GRANT INSERT, UPDATE ON heartbeat TO STREAMKAP_USER;
INSERT INTO heartbeat (text) VALUES ('test_heartbeat');
- Streamkap should start updating the record in the heartbeat table using this command every 1 second
UPDATE heartbeat SET text = 'updated_heartbeat' WHERE id = 1;
- Look for entries in the heartbeat table to verify this is working
Updated 28 days ago