diff --git a/external_plugin_deps.bzl b/external_plugin_deps.bzl
index 49673fa..0ae5935 100644
--- a/external_plugin_deps.bzl
+++ b/external_plugin_deps.bzl
@@ -3,8 +3,8 @@
 def external_plugin_deps():
     maven_jar(
         name = "kafka-client",
-        artifact = "org.apache.kafka:kafka-clients:2.3.1",
-        sha1 = "21664b0318d201ec412f9b02357b07ba94009c87",
+        artifact = "org.apache.kafka:kafka-clients:2.8.2",
+        sha1 = "b078c76ec2cf00803417c6505ebc8bef1a66d4db",
     )
 
     maven_jar(
diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaRestProducer.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaRestProducer.java
index 2f8b51c..f418963 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaRestProducer.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaRestProducer.java
@@ -30,6 +30,7 @@
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.entity.ContentType;
 import org.apache.http.entity.StringEntity;
+import org.apache.kafka.clients.consumer.ConsumerGroupMetadata;
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.clients.producer.Callback;
 import org.apache.kafka.clients.producer.Producer;
@@ -71,6 +72,13 @@
   }
 
   @Override
+  public void sendOffsetsToTransaction(
+      Map<TopicPartition, OffsetAndMetadata> map, ConsumerGroupMetadata consumerGroupMetadata)
+      throws ProducerFencedException {
+    unsupported();
+  }
+
+  @Override
   public void commitTransaction() throws ProducerFencedException {
     unsupported();
   }