Class KafkaExporter.Builder

java.lang.Object

io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

Enclosing class:

KafkaExporter

public static final class KafkaExporter.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
KafkaExporter	build()
KafkaExporter.Builder	setAdminClientProperties(Properties adminClientProperties)
KafkaExporter.Builder	setCreateTopic(boolean createTopic)
KafkaExporter.Builder	setMetricsPredicate(Predicate<Keyed> metricsPredicate)
KafkaExporter.Builder	setName(String name)
KafkaExporter.Builder	setProducer(org.apache.kafka.clients.producer.Producer<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)

Methods inherited from class java.lang.Object

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

Method Details

setMetricsPredicate

public KafkaExporter.Builder setMetricsPredicate(Predicate<Keyed> metricsPredicate)

setName

public KafkaExporter.Builder setName(String name)

setAdminClientProperties

public KafkaExporter.Builder setAdminClientProperties(Properties adminClientProperties)

setTopicName

public KafkaExporter.Builder setTopicName(String topicName)

setCreateTopic

public KafkaExporter.Builder setCreateTopic(boolean createTopic)

setTopicReplicas

public KafkaExporter.Builder setTopicReplicas(int topicReplicas)

setTopicPartitions

public KafkaExporter.Builder setTopicPartitions(int topicPartitions)

setTopicConfig

public KafkaExporter.Builder setTopicConfig(Map<String,String> topicConfig)

setProducer

public KafkaExporter.Builder setProducer(org.apache.kafka.clients.producer.Producer<byte[], io.opentelemetry.proto.metrics.v1.MetricsData> producer)

build

public KafkaExporter build()