kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [kafka] Diff for: [GitHub] Fokko closed pull request #6142: [KAFKA-7818] Make the KafkaConsumer AutoCloseable
Date Mon, 14 Jan 2019 23:19:31 GMT
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 7a5485b810a..0ad5e700a9a 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -547,7 +547,7 @@
  * the consumer threads can hash into these queues using the TopicPartition to ensure in-order
consumption and simplify
  * commit.
  */
-public class KafkaConsumer<K, V> implements Consumer<K, V> {
+public class KafkaConsumer<K, V> implements Consumer<K, V>, AutoCloseable {
 
     private static final long NO_CURRENT_THREAD = -1L;
     private static final AtomicInteger CONSUMER_CLIENT_ID_SEQUENCE = new AtomicInteger(1);


With regards,
Apache Git Services

Mime
View raw message