Constructor and Description |
---|
TierTopicConsumerSupplier(Supplier<Map<String,Object>> clientConfigs,
String clusterId,
int brokerId,
String clientIdSuffix) |
TierTopicConsumerSupplier(TierTopicManagerConfig config,
String clientIdSuffix) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> |
get() |
public TierTopicConsumerSupplier(TierTopicManagerConfig config, String clientIdSuffix)