THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- org.apache.kafka.streams.KafkaStreams
- org.apache.kafka.streams.processor.internals.RecordCollectorImpl
- org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
- org.apache.kafka.connect.transforms.TimestampRouter
- org.apache.kafka.tools.VerifiableProducer
Proposed Changes
Changes are similar to thisHere are the proposed changes:
org.apache.kafka.streams.KafkaStreams
Code Block |
---|
public class KafkaStreams implements AutoCloseable{ ... public void close() ... } |
org.apache.kafka.streams.processor.internals.RecordCollectorImpl
Code Block |
---|
public class RecordCollectorImpl implements RecordCollector, AutoCloseable { ... } |
org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
Code Block |
---|
public class MetricGroup implements AutoCloseable { ... } |
org.apache.kafka.connect.transforms.TimestampRouter
Code Block |
---|
public class TimestampRouter<R extends ConnectRecord<R>> implements Transformation<R>, AutoCloseable { ... } |
org.apache.kafka.tools.VerifiableProducVerifiableProducer
Code Block |
---|
public class VerifiableProducer implements Closeable { ... } |
...