public static final class KafkaCollector.Builder extends CollectorComponent.Builder
Modifier and Type | Method and Description |
---|---|
KafkaCollector.Builder |
bootstrapServers(String bootstrapServers)
The bootstrapServers connect string, ex.
|
KafkaCollector |
build() |
KafkaCollector.Builder |
groupId(String groupId)
The consumer group this process is consuming on behalf of.
|
KafkaCollector.Builder |
metrics(CollectorMetrics metrics) |
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 |
sampler(CollectorSampler sampler) |
KafkaCollector.Builder |
storage(StorageComponent storage) |
KafkaCollector.Builder |
streams(int streams)
Count of threads consuming the topic.
|
KafkaCollector.Builder |
topic(String topic)
Topic zipkin spans will be consumed from.
|
public KafkaCollector.Builder storage(StorageComponent storage)
storage
in class CollectorComponent.Builder
public KafkaCollector.Builder sampler(CollectorSampler sampler)
sampler
in class CollectorComponent.Builder
public KafkaCollector.Builder metrics(CollectorMetrics metrics)
metrics
in class CollectorComponent.Builder
public KafkaCollector.Builder topic(String topic)
public KafkaCollector.Builder bootstrapServers(String bootstrapServers)
public KafkaCollector.Builder groupId(String groupId)
public KafkaCollector.Builder streams(int streams)
public final KafkaCollector.Builder overrides(Map<String,?> overrides)
For example: Only consume spans since you connected by setting the below.
Map<String, String> overrides = new LinkedHashMap<>();
overrides.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
builder.overrides(overrides);
ConsumerConfig
public KafkaCollector build()
build
in class CollectorComponent.Builder
Copyright © 2015–2018 OpenZipkin. All rights reserved.