...

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

Proposed Changes

Changes are similar to thisHere are the proposed changes:

org.apache.kafka.streams.KafkaStreams

public class KafkaStreams implements AutoCloseable{
...
	public void close()
...
}

org.apache.kafka.streams.processor.internals.RecordCollectorImpl

public class RecordCollectorImpl implements RecordCollector, AutoCloseable {
...
}

org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup

public class MetricGroup implements AutoCloseable {
...
}

org.apache.kafka.connect.transforms.TimestampRouter

public class TimestampRouter<R extends ConnectRecord<R>> implements Transformation<R>, AutoCloseable {
...
}

org.apache.kafka.tools.VerifiableProducVerifiableProducer

public class VerifiableProducer implements Closeable {
...
}

...