diff --git kafka-handler/pom.xml kafka-handler/pom.xml
index f907e9ddf0..3f5784912c 100644
--- kafka-handler/pom.xml
+++ kafka-handler/pom.xml
@@ -30,7 +30,7 @@
..
- 2.0.0
+ 2.2.0
kafka-handler
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..b93d941e0d 100644
--- kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java
+++ kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java
@@ -39,6 +39,7 @@
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;
@@ -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() {