David Mollitor created KAFKA-9400: ------------------------------------- Summary: Make Consumer Class Extend AutoCloseable Key: KAFKA-9400 URL: https://issues.apache.org/jira/browse/KAFKA-9400 Project: Kafka Issue Type: Improvement Reporter: David Mollitor
{quote} The consumer maintains TCP connections to the necessary brokers to fetch data. Failure to close the consumer after use will leak these connections. {quote} https://github.com/apache/kafka/blob/505e8240cd29fe3f0effa96d794bc711d5c8423b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L92-L94 To assist in making sure that consumers are closed, please have the Consumer interface extend AutoCloseable. https://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html -- This message was sent by Atlassian Jira (v8.3.4#803005)