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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
prepare(Map<String,Object> topoConf, TopologyContext context)
-
-
-
Method Detail
-
prepare
void prepare(Map<String,Object> topoConf, TopologyContext context)
-
-