Bump kafka-clients to v2.3.1
Bug: Issue 322064239
Change-Id: I09f5b1f941284fbf29b631067e1d8c63b4b7650b
(cherry picked from commit 4b38d06b6c6522b7290e4c847d2240886dde2beb)
diff --git a/external_plugin_deps.bzl b/external_plugin_deps.bzl
index 1f23015..49673fa 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.1.1",
- sha1 = "a7b72831768ccfd69128385130409ae1a0e52f5f",
+ artifact = "org.apache.kafka:kafka-clients:2.3.1",
+ sha1 = "21664b0318d201ec412f9b02357b07ba94009c87",
)
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 8799cef..2f8b51c 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
@@ -21,6 +21,7 @@
import com.googlesource.gerrit.plugins.kafka.rest.KafkaRestClient;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
+import java.time.Duration;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Future;
@@ -126,6 +127,11 @@
close();
}
+ @Override
+ public void close(Duration timeout) {
+ close();
+ }
+
private String getRecordAsJson(ProducerRecord<String, String> record) {
return String.format(
"{\"records\":[{\"key\":\"%s\",\"value\":%s}]}", record.key(), record.value());
