public class ProducerBuilder extends java.lang.Object implements TierTopicProducerBuilder
Constructor and Description |
---|
ProducerBuilder(TierTopicManagerConfig config) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]> |
setupProducer(java.lang.String bootstrapServers)
Setup the internal kafka producer for the tier topic manager.
|
static boolean |
tierProducer(java.lang.String clientId) |
public ProducerBuilder(TierTopicManagerConfig config)
public org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]> setupProducer(java.lang.String bootstrapServers)
setupProducer
in interface TierTopicProducerBuilder
public static boolean tierProducer(java.lang.String clientId)