Upgrade Kafka client to v2.8.2 It is a non-breaking change, and all clients should continue to function without any disruptions. Please review the release notes [1] and upgrade documentation [2] for more details. References: [1] https://archive.apache.org/dist/kafka/2.8.2/RELEASE_NOTES.html [2] https://kafka.apache.org/28/documentation.html#upgrade Bug: Issue 323031722 Change-Id: Ica0dc793d7fa0c2d40489b2fd8a5522dc5c2d487
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(); }