alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8100 Wait for streaming instead of starting connector

Browse Source 
If we stop the connector short after its start, we need to wait for
streaming phase, i.e. wait for starting all connector tasks.
Waiting for connector start return `true` when connector begins to start
its tasks, but to prevent leaking of the resources, async engine doesn't
allow stopping the connector until all its tasks are started. Therefore
when using async. engine, we have to wait for tasks to be started before
stopping the connector, otherwise exception is thrown.
This commit is contained in:
Vojtech Juranek 2024-07-30 10:50:47 +02:00 committed by Jiri Pechanec
parent 0c45719a9d
commit e583599d22
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-embedded/src/test/java/io/debezium/pipeline/notification/AbstractNotificationsIT.java
View File

@ -274,7 +274,7 @@ public void sinkNotificationWillCorrectlySaveOffsetAfterSnapshot() throws Interr
.with(SinkNotificationChannel.NOTIFICATION_TOPIC, "io.debezium.notification")
.with(CommonConnectorConfig.NOTIFICATION_ENABLED_CHANNELS, "sink"));
assertConnectorIsRunning();
waitForStreamingRunning(connector(), server(), "streaming", task());
}
private void assertTableNotificationsSentToJmx(List<Notification> notifications, String tableName) {