Adding tombstone capability

thake · Nov 18, 2020 · 7741899 · 7741899
1 parent 6e21030
commit 7741899
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/kotlin/com/github/thake/logminer/kafka/connect/LongStatementsTest.kt b/src/test/kotlin/com/github/thake/logminer/kafka/connect/LongStatementsTest.kt
@@ -41,6 +41,8 @@ class LongStatementsTest : AbstractCdcSourceIntegrationTest() {
         val entries = 100
         val updateExecutions = 10
         val finished = CountDownLatch(1)
+        val pollConnection = openConnection()
+        val cdcSource = getCdcSource(dictionarySource)
         Thread {
             val conn = openConnection()
             conn.prepareStatement(insertStr).use { stmt ->
@@ -63,9 +65,7 @@ class LongStatementsTest : AbstractCdcSourceIntegrationTest() {
         }.start()
         //Wait for the initialization
         Thread.sleep(2000)
-        val pollConnection = openConnection()
         var totalReturnedResults = 0
-        val cdcSource = getCdcSource(dictionarySource)
         do {
             val results = cdcSource.getResults(pollConnection)
             assertNotNull(results)