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 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 and Description
static class	KafkaCollector.Builder Configuration including defaults needed to consume spans from a Kafka topic.

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static KafkaCollector.Builder builder()

start

public KafkaCollector start()

Specified by:

start in class CollectorComponent

check

public CheckResult check()

Overrides:

check in class Component

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class Component