diff --git a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
index a8d28e1..27de527 100644
--- a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
+++ b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
@@ -179,8 +179,8 @@
         }
 
         try {
-            for (int i = 0; i < threadCnt + 1; i++)
-                runners.get(i).join();
+            for (Thread run: runners)
+                run.join();
         }
         catch (InterruptedException e) {
             stopped.set(true);