org.apache.heron.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, org.apache.heron.api.topology.TopologyContext context)

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

onCompletion

Method Detail

prepare

void prepare(Map<String,Object> topoConf,
             org.apache.heron.api.topology.TopologyContext context)