Package zipkin2.collector.kafka

Class KafkaCollector

java.lang.Object

zipkin2.Component

zipkin2.collector.CollectorComponent

zipkin2.collector.kafka.KafkaCollector

All Implemented Interfaces:

Closeable, AutoCloseable

public final class KafkaCollector
extends zipkin2.collector.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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	KafkaCollector.Builder	Configuration including defaults needed to consume spans from a Kafka topic.

Method Summary

Modifier and Type	Method	Description
static KafkaCollector.Builder	builder()
zipkin2.CheckResult	check()
void	close()
KafkaCollector	start()
final String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

builder

public static KafkaCollector.Builder builder()

start

public KafkaCollector start()

Specified by:

start in class zipkin2.collector.CollectorComponent

check

public zipkin2.CheckResult check()

Overrides:

check in class zipkin2.Component

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class zipkin2.Component

toString

public final String toString()

Overrides:

toString in class Object