DBZ-6440 Init Kafka signal channel
This commit is contained in:
parent
f70b215b51
commit
6c338754b3
@ -96,6 +96,7 @@ public MySqlReadOnlyIncrementalSnapshotChangeEventSource(RelationalDatabaseConne
|
||||
public void init(MySqlPartition partition, OffsetContext offsetContext) {
|
||||
super.init(partition, offsetContext);
|
||||
|
||||
kafkaSignal.init(connectorConfig);
|
||||
Long signalOffset = getContext().getSignalOffset();
|
||||
if (signalOffset != null) {
|
||||
kafkaSignal.seek(signalOffset);
|
||||
|
Loading…
Reference in New Issue
Block a user