public interface  org.apache.kafkaesque.clients.producer.ProducerInterceptor extends java.lang.Object implements org.apache.kafkaesque.common.Configurable
{
public abstract org.apache.kafkaesque.clients.producer.ProducerRecord onSend(org.apache.kafkaesque.clients.producer.ProducerRecord);
public abstract void onAcknowledgement(org.apache.kafkaesque.clients.producer.RecordMetadata, java.lang.Exception);
public abstract void close();
}