public class TierTopicProducerSupplier
extends java.lang.Object
implements java.util.function.Supplier<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>
Constructor and Description |
---|
TierTopicProducerSupplier(TierTopicManagerConfig config) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
clientId(java.lang.String clusterId,
int brokerId,
long instanceId) |
org.apache.kafka.clients.producer.Producer<byte[],byte[]> |
get() |
public TierTopicProducerSupplier(TierTopicManagerConfig config)
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> get()
get
in interface java.util.function.Supplier<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>
public static java.lang.String clientId(java.lang.String clusterId, int brokerId, long instanceId)