public class ConsumerBuilder extends java.lang.Object implements TierTopicConsumerBuilder
Constructor and Description |
---|
ConsumerBuilder(TierTopicManagerConfig config) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> |
setupConsumer(java.lang.String bootstrapServers,
java.lang.String topicName,
java.lang.String clientIdSuffix)
Setup the internal kafka consumer for the tier topic manager.
|
public ConsumerBuilder(TierTopicManagerConfig config)
public org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> setupConsumer(java.lang.String bootstrapServers, java.lang.String topicName, java.lang.String clientIdSuffix)
setupConsumer
in interface TierTopicConsumerBuilder
topicName
- the tier topic name.