Fix Kafka API

rayokota · Dec 24, 2024 · 825c459 · 825c459
1 parent b113cbe
commit 825c459
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbLeaderElector.java b/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbLeaderElector.java
@@ -24,6 +24,7 @@
 import org.apache.kafka.clients.ClientUtils;
 import org.apache.kafka.clients.CommonClientConfigs;
 import org.apache.kafka.clients.Metadata;
+import org.apache.kafka.clients.MetadataRecoveryStrategy;
 import org.apache.kafka.clients.NetworkClient;
 import org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient;
 import org.apache.kafka.common.KafkaException;
@@ -150,7 +151,8 @@ public KarelDbLeaderElector(KarelDbConfig config, KarelDbEngine engine) throws K
                 time,
                 true,
                 new ApiVersions(),
-                logContext);
+                logContext,
+                MetadataRecoveryStrategy.NONE);
 
             this.client = new ConsumerNetworkClient(
                 logContext,