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

DBZ-4720 wait for pulsarClient

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

3
debezium-server/debezium-server-pulsar/src/test/java/io/debezium/server/pulsar/PulsarIT.java
View File

@ -84,6 +84,9 @@ void connectorCompleted(@Observes ConnectorCompletedEvent event) throws Exceptio
@Test
public void testPulsar() throws Exception {
Awaitility.await().atMost(Duration.ofSeconds(PulsarTestConfigSource.waitForSeconds())).until(() -> {
return pulsarClient != null;
});
final Consumer<String> consumer = pulsarClient.newConsumer(Schema.STRING)
.topic(TOPIC_NAME)
.subscriptionName("test-" + UUID.randomUUID())