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