public interface PreparableCallback extends org.apache.kafka.clients.producer.Callback, Serializable
Serializable callback for use with the KafkaProducer on KafkaBolt.
Modifier and Type | Method and Description |
---|---|
void |
prepare(Map<String,Object> topoConf,
TopologyContext context) |
void prepare(Map<String,Object> topoConf, TopologyContext context)
Copyright © 2022 The Apache Software Foundation. All rights reserved.