Status

Current state: Under DiscussionAccepted (2.2.0)

Discussion thread: Link 

JIRA: KAFKA-7402

...

1. org.apache.kafka.streams.KafkaStreams
2. org.apache.kafka.streams.processor.internals.RecordCollector
3. org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
4. org.apache.kafka.connect.transforms.TimestampRouter
5. org.apache.kafka.tools.VerifiableProducer
6. org.apache.kafka.connect.runtime.WorkerConnector.ConnectorMetricsGroup
7. org.apache.kafka.common.record.MemoryRecordsBuilder
8. org.apache.kafka.common.metrics.MetricsReporter
9. org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin
10. org.apache.kafka.common.network.KafkaChannel
11. org.apache.kafka.clients.consumer.ConsumerInterceptor
12. org.apache.kafka.common.network.Selector.SelectorMetrics
13. org.apache.kafka.clients.consumer.internals.AbstractCoordinator.HeartbeatThread

...

• This change will not have any backward compatibility issues. It is legal to implement this AutoClosable interface without declaring "throws Exception" on close(), so the close() method signature won't be changed.  

...