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

DBZ-4720 wait for kafka consumer

Browse Source
This commit is contained in:
ggaborg 2022-11-14 11:11:45 +02:00 committed by Jiri Pechanec
parent edca139355
commit 1aca4f5781
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-server/debezium-server-kafka/src/test/java/io/debezium/server/kafka/KafkaIT.java
View File

@ -79,7 +79,9 @@ static void stop() throws Exception {
@Test
public void testKafka() throws Exception {
Awaitility.await().atMost(Duration.ofSeconds(KafkaTestConfigSource.waitForSeconds())).until(() -> {
return consumer != null;
});
consumer.subscribe(Arrays.asList(TOPIC_NAME));
final List<ConsumerRecord<String, String>> actual = new ArrayList<>();