THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

This line was added.
This line was removed.
Formatting was changed.

...

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

...