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..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() {