...

Changes are similar to this:

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.VerifiableProduc

public class VerifiableProducer implements Closeable {
...
}

Compatibility, Deprecation, and Migration Plan

...