KafkaCollector (Collector: Kafka 0.10+ 2.16.0 API)

java.lang.Object
- zipkin2.Component
- - zipkin2.collector.CollectorComponent
  - - zipkin2.collector.kafka.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.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class KafkaCollector.Builder
Configuration including defaults needed to consume spans from a Kafka topic.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static KafkaCollector.Builder`	`builder()`
`CheckResult`	`check()`
`void`	`close()`
`KafkaCollector`	`start()`
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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 java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Overrides:
    
    close in class Component
  - toString
```
public final java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object