public static final class KafkaExporter.Builder extends Object
Modifier and Type | Method and Description |
---|---|
KafkaExporter |
build() |
KafkaExporter.Builder |
setAdminClientProperties(Properties adminClientProperties) |
KafkaExporter.Builder |
setContext(Context context) |
KafkaExporter.Builder |
setCreateTopic(boolean createTopic) |
KafkaExporter.Builder |
setMetricsPredicate(Predicate<Keyed> metricsPredicate) |
KafkaExporter.Builder |
setName(String name) |
KafkaExporter.Builder |
setProducer(org.apache.kafka.clients.producer.KafkaProducer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> producer) |
KafkaExporter.Builder |
setTopicConfig(Map<String,String> topicConfig) |
KafkaExporter.Builder |
setTopicName(String topicName) |
KafkaExporter.Builder |
setTopicPartitions(int topicPartitions) |
KafkaExporter.Builder |
setTopicReplicas(int topicReplicas) |
public KafkaExporter.Builder setContext(Context context)
public KafkaExporter.Builder setMetricsPredicate(Predicate<Keyed> metricsPredicate)
public KafkaExporter.Builder setName(String name)
public KafkaExporter.Builder setAdminClientProperties(Properties adminClientProperties)
public KafkaExporter.Builder setTopicName(String topicName)
public KafkaExporter.Builder setCreateTopic(boolean createTopic)
public KafkaExporter.Builder setTopicReplicas(int topicReplicas)
public KafkaExporter.Builder setTopicPartitions(int topicPartitions)
public KafkaExporter.Builder setTopicConfig(Map<String,String> topicConfig)
public KafkaExporter.Builder setProducer(org.apache.kafka.clients.producer.KafkaProducer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> producer)
public KafkaExporter build()