public interface TierTopicConsumerBuilder
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> |
setupConsumer(java.lang.String bootstrapServers,
java.lang.String topicName,
java.lang.String clientIdSuffix) |