Package org.apache.storm.kafka.bolt
Interface PreparableCallback
- All Superinterfaces:
org.apache.kafka.clients.producer.Callback
,Serializable
public interface PreparableCallback
extends org.apache.kafka.clients.producer.Callback, Serializable
Serializable callback for use with the KafkaProducer on KafkaBolt.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
prepare
(Map<String, Object> topoConf, TopologyContext context) Methods inherited from interface org.apache.kafka.clients.producer.Callback
onCompletion
-
Method Details
-
prepare
-