public interface  org.apache.kafkaesque.clients.consumer.ConsumerInterceptor extends java.lang.Object implements org.apache.kafkaesque.common.Configurable, java.lang.AutoCloseable
{
public abstract org.apache.kafkaesque.clients.consumer.ConsumerRecords onConsume(org.apache.kafkaesque.clients.consumer.ConsumerRecords);
public abstract void onCommit(java.util.Map);
public abstract void close();
}