...

1. org.apache.kafka.connect.runtime.WorkerConnector
2. org.apache.kafka.common.record.MemoryRecordsBuilder
3. org.apache.kafka.common.metrics.MetricsReporter
4. org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin
5. org.apache.kafka.common.network.KafkaChannel
6. org.apache.kafka.clients.consumer.ConsumerInterceptor
7. org.apache.kafka.common.network.Selector.SelectorMetrics
8. org.apache.kafka.clients.consumer.internals.AbstractCoordinator.HeartbeatThread

Proposed Changes

Here are some examples for the proposed changes:

org.apache.kafka.streams.KafkaStreams

...

public class VerifiableProducer implements AutoCloseable {
...
}

Others For Chia-ping's list, the changes are similar, will be added here latervery similar ( ...implements AutoCloseable). Specific changes can be added if requested.

Compatibility, Deprecation, and Migration Plan

...