Modifier and Type | Method and Description |
---|---|
KafkaCollector.Builder |
KafkaCollector.Builder.bootstrapServers(String bootstrapServers)
The bootstrapServers connect string, ex.
|
static KafkaCollector.Builder |
KafkaCollector.builder() |
KafkaCollector.Builder |
KafkaCollector.Builder.groupId(String groupId)
The consumer group this process is consuming on behalf of.
|
KafkaCollector.Builder |
KafkaCollector.Builder.metrics(CollectorMetrics metrics) |
KafkaCollector.Builder |
KafkaCollector.Builder.overrides(Map<String,?> overrides)
By default, a consumer will be built from properties derived from builder defaults, as well
as "auto.offset.reset" -> "earliest".
|
KafkaCollector.Builder |
KafkaCollector.Builder.sampler(CollectorSampler sampler) |
KafkaCollector.Builder |
KafkaCollector.Builder.storage(StorageComponent storage) |
KafkaCollector.Builder |
KafkaCollector.Builder.streams(int streams)
Count of threads consuming the topic.
|
KafkaCollector.Builder |
KafkaCollector.Builder.topic(String topic)
Topic zipkin spans will be consumed from.
|
Copyright © 2015–2018 OpenZipkin. All rights reserved.