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 void |
addBaseProperties(java.util.Properties properties,
java.lang.String clientId,
java.lang.Integer requestTimeoutMs) |
static java.lang.String |
clientId(java.lang.String clusterId,
int brokerId,
long instanceId) |
org.apache.kafka.clients.producer.Producer<byte[],byte[]> |
get() |
static java.util.Properties |
properties(TierTopicManagerConfig config,
java.lang.String clientId) |
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)
public static void addBaseProperties(java.util.Properties properties, java.lang.String clientId, java.lang.Integer requestTimeoutMs)
public static java.util.Properties properties(TierTopicManagerConfig config, java.lang.String clientId)