Constructor and Description |
---|
TierTopicProducerSupplier(TierTopicManagerConfig config) |
Modifier and Type | Method and Description |
---|---|
static void |
addBaseProperties(Properties properties,
String clientId,
Integer requestTimeoutMs) |
static String |
clientId(String clusterId,
int brokerId,
long instanceId) |
org.apache.kafka.clients.producer.Producer<byte[],byte[]> |
get() |
static Properties |
properties(TierTopicManagerConfig config,
String clientId) |
public TierTopicProducerSupplier(TierTopicManagerConfig config)
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> get()
public static void addBaseProperties(Properties properties, String clientId, Integer requestTimeoutMs)
public static Properties properties(TierTopicManagerConfig config, String clientId)