Skip to content

Commit db709a2

Browse files
committed
Temp commit for numEntriesExpectAfterStart
1 parent b04cc48 commit db709a2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java

+1
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ public class DebeziumMongoDbSourceTester extends SourceTester<DebeziumMongoDbCon
4040
public DebeziumMongoDbSourceTester(PulsarCluster cluster) {
4141
super(NAME);
4242
this.pulsarCluster = cluster;
43+
this.numEntriesExpectAfterStart = 0;
4344
pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
4445

4546
sourceConfig.put("mongodb.name", "dbserver1");

0 commit comments

Comments
 (0)