Upgrade to Kafka 3.7.0

rayokota · Apr 11, 2024 · a7013ed · a7013ed
1 parent 67133b6
commit a7013ed
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/kafka-graphs-core/src/main/java/io/kgraph/pregel/PregelConsumer.java b/kafka-graphs-core/src/main/java/io/kgraph/pregel/PregelConsumer.java
@@ -35,6 +35,7 @@
 import org.apache.kafka.common.MetricName;
 import org.apache.kafka.common.PartitionInfo;
 import org.apache.kafka.common.TopicPartition;
+import org.apache.kafka.common.Uuid;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -186,6 +187,11 @@ public Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> part
         return kafkaConsumer.committed(partitions, timeout);
     }
 
+    @Override
+    public Uuid clientInstanceId(Duration timeout) {
+        return kafkaConsumer.clientInstanceId(timeout);
+    }
+
     @Override
     public Map<MetricName, ? extends Metric> metrics() {
         return kafkaConsumer.metrics();

diff --git a/pom.xml b/pom.xml
@@ -38,7 +38,7 @@
 
     <properties>
         <curator.version>5.6.0</curator.version>
-        <kafka.version>3.6.1</kafka.version>
+        <kafka.version>3.7.0</kafka.version>
         <kafka.scala.version>2.13</kafka.scala.version>
         <kryo.version>5.5.0</kryo.version>
         <logback.version>1.4.14</logback.version>