From 11bc0521a895dbf1cec8480018b169f574ad9acc Mon Sep 17 00:00:00 2001
From: NSAmelchev <nsamelchev@gmail.com>
Date: Thu, 15 Sep 2022 13:44:53 +0300
Subject: [PATCH] debug1

---
 .../apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java
index 581e74c0a..5f9079eae 100644
--- a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java
+++ b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java
@@ -89,7 +89,7 @@ public KafkaToIgniteMetadataUpdater(
     /** Polls all available records from metadata topic and applies it to Ignite. */
     public synchronized void updateMetadata() {
         while (true) {
-            ConsumerRecords<Void, byte[]> recs = cnsmr.poll(Duration.ofMillis(kafkaReqTimeout));
+            ConsumerRecords<Void, byte[]> recs = cnsmr.poll(Duration.ofMillis(300));
 
             if (recs.count() == 0)
                 return;