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
Additions provided by Chia-pingChia-Ping Tsai:
- org.apache.kafka.connect.runtime.WorkerConnector
- org.apache.kafka.common.record.MemoryRecordsBuilder
- org.apache.kafka.common.metrics.MetricsReporter
- org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin
- org.apache.kafka.common.network.KafkaChannel
- org.apache.kafka.clients.consumer.ConsumerInterceptor
- org.apache.kafka.common.network.Selector.SelectorMetrics
- org.apache.kafka.clients.consumer.internals.AbstractCoordinator.HeartbeatThread
Classes that should be implementing Closeable:
- org.apache.kafka.tools.VerifiableProducer
Proposed Changes
Here are the proposed changes:
...