Class KafkaCollector

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public final class KafkaCollector
    extends CollectorComponent
    This collector polls a Kafka topic for messages that contain TBinaryProtocol big-endian encoded lists of spans. These spans are pushed to a span consumer.

    This collector uses a Kafka 0.10+ consumer.