Modifier and Type | Field and Description |
---|---|
protected org.apache.kafka.clients.producer.Producer<String,T> |
producer |
Constructor and Description |
---|
EventProducer() |
Modifier and Type | Method and Description |
---|---|
void |
produceAsync(String topicName,
String key,
Object object,
org.apache.kafka.clients.producer.Callback callback) |
void |
produceFireAndForget(String topicName,
String key,
Object object) |
void |
produceSync(String topicName,
String key,
Object object) |
void |
start(Properties properties) |
void |
stop() |
public void start(Properties properties)
public void produceFireAndForget(String topicName, String key, Object object)
produceFireAndForget
in interface Producer
public void produceSync(String topicName, String key, Object object)
produceSync
in interface Producer
public void produceAsync(String topicName, String key, Object object, org.apache.kafka.clients.producer.Callback callback)
produceAsync
in interface Producer
Copyright © 2001–2019 JBoss by Red Hat. All rights reserved.