diff --git kafka-handler/pom.xml kafka-handler/pom.xml
index f907e9ddf0..c7c2e4848c 100644
--- kafka-handler/pom.xml
+++ kafka-handler/pom.xml
@@ -30,7 +30,7 @@
..
- 2.0.0
+ 2.2.0
kafka-handler
@@ -94,7 +94,6 @@
test
test
-
org.apache.kafka
kafka_2.11
@@ -108,6 +107,12 @@
${kafka.version}
test
+
+ org.apache.zookeeper
+ zookeeper
+ 3.4.7
+ test
+
org.slf4j
slf4j-api
diff --git kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java
index 2270e08e2c..ba27233f86 100644
--- kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java
+++ kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java
@@ -39,11 +39,12 @@
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
+import java.time.Duration;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
+
/**
* Kafka Producer with public methods to extract the producer state then resuming transaction in another process.
@@ -107,8 +108,8 @@
kafkaProducer.close();
}
- @Override public void close(long timeout, TimeUnit unit) {
- kafkaProducer.close(timeout, unit);
+ @Override public void close(Duration duration) {
+ kafkaProducer.close(duration);
}
@Override public void flush() {