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 Type	Method and Description
void	prepare(Map<String,Object> topoConf, TopologyContext context)

Methods inherited from interface org.apache.kafka.clients.producer.Callback

onCompletion

Method Detail

prepare

void prepare(Map<String,Object> topoConf,
             TopologyContext context)