public class TierTopicConsumerSupplier
extends java.lang.Object
implements java.util.function.Supplier<org.apache.kafka.clients.consumer.Consumer<byte[],byte[]>>
Constructor and Description |
---|
TierTopicConsumerSupplier(TierTopicManagerConfig config,
java.lang.String clientIdSuffix) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> |
get() |
public TierTopicConsumerSupplier(TierTopicManagerConfig config, java.lang.String clientIdSuffix)