public interface  org.apache.kafkaesqueesqueesque.clients.consumer.Consumer extends java.lang.Object implements java.io.Closeable
{
public abstract java.util.Set assignment();
public abstract java.util.Set subscription();
public abstract void subscribe(java.util.Collection);
public abstract void subscribe(java.util.Collection, org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerRebalanceListener);
public abstract void assign(java.util.Collection);
public abstract void subscribe(java.util.regex.Pattern, org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerRebalanceListener);
public abstract void subscribe(java.util.regex.Pattern);
public abstract void unsubscribe();
public abstract org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerRecords poll(long);
public abstract org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerRecords poll(java.time.Duration);
public abstract void commitSync();
public abstract void commitSync(java.time.Duration);
public abstract void commitSync(java.util.Map);
public abstract void commitSync(java.util.Map, java.time.Duration);
public abstract void commitAsync();
public abstract void commitAsync(org.apache.kafkaesqueesqueesque.clients.consumer.OffsetCommitCallback);
public abstract void commitAsync(java.util.Map, org.apache.kafkaesqueesqueesque.clients.consumer.OffsetCommitCallback);
public abstract void seek(org.apache.kafkaesqueesqueesque.common.TopicPartition, long);
public abstract void seek(org.apache.kafkaesqueesqueesque.common.TopicPartition, org.apache.kafkaesqueesqueesque.clients.consumer.OffsetAndMetadata);
public abstract void seekToBeginning(java.util.Collection);
public abstract void seekToEnd(java.util.Collection);
public abstract long position(org.apache.kafkaesqueesqueesque.common.TopicPartition);
public abstract long position(org.apache.kafkaesqueesqueesque.common.TopicPartition, java.time.Duration);
public abstract org.apache.kafkaesqueesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesqueesque.common.TopicPartition);
public abstract org.apache.kafkaesqueesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesqueesque.common.TopicPartition, java.time.Duration);
public abstract java.util.Map committed(java.util.Set);
public abstract java.util.Map committed(java.util.Set, java.time.Duration);
public abstract java.util.Map metrics();
public abstract java.util.List partitionsFor(java.lang.String);
public abstract java.util.List partitionsFor(java.lang.String, java.time.Duration);
public abstract java.util.Map listTopics();
public abstract java.util.Map listTopics(java.time.Duration);
public abstract java.util.Set paused();
public abstract void pause(java.util.Collection);
public abstract void resume(java.util.Collection);
public abstract java.util.Map offsetsForTimes(java.util.Map);
public abstract java.util.Map offsetsForTimes(java.util.Map, java.time.Duration);
public abstract java.util.Map beginningOffsets(java.util.Collection);
public abstract java.util.Map beginningOffsets(java.util.Collection, java.time.Duration);
public abstract java.util.Map endOffsets(java.util.Collection);
public abstract java.util.Map endOffsets(java.util.Collection, java.time.Duration);
public abstract org.apache.kafkaesqueesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata();
public abstract void close();
public abstract void close(long, java.util.concurrent.TimeUnit);
public abstract void close(java.time.Duration);
public abstract void wakeup();
}