...

1. org.apache.kafka.streams.KafkaStreams
2. org.apache.kafka.streams.processor.internals.RecordCollectorImpl
3. org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
4. org.apache.kafka.connect.transforms.TimestampRouter
5. org.apache.kafka.tools.VerifiableProducer
   
   

Additions provided by Chia-pingChia-Ping Tsai:

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

...

1. org.apache.kafka.tools.VerifiableProducer

Proposed Changes

Here are the proposed changes:

...

public class VerifiableProducer implements CloseableAutoCloseable {
...
}

Others changes are similar, will be added here later.

...