THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- org.apache.kafka.streams.KafkaStreams
- org.apache.kafka.streams.processor.internals.RecordCollectorImplRecordCollector
- org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
- org.apache.kafka.connect.transforms.TimestampRouter
- org.apache.kafka.tools.VerifiableProducer
...
org.apache.kafka.streams.processor.internals.RecordCollectorImplRecordCollector
Code Block |
---|
public classinterface RecordCollectorImpl implements RecordCollector,RecordCollector extends AutoCloseable { ... } |
org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup
...