public static interface ConsumerSeekAware.ConsumerSeekCallback
| Modifier and Type | Method and Description |
|---|---|
void |
seek(java.lang.String topic,
int partition,
long offset)
Queue a seek operation to the consumer.
|
void |
seekToBeginning(java.lang.String topic,
int partition)
Queue a seekToBeginning operation to the consumer.
|
void |
seekToEnd(java.lang.String topic,
int partition)
Queue a seekToEnd operation to the consumer.
|
void seek(java.lang.String topic,
int partition,
long offset)
topic - the topic.partition - the partition.offset - the offset (absolute).void seekToBeginning(java.lang.String topic,
int partition)
topic - the topic.partition - the partition.void seekToEnd(java.lang.String topic,
int partition)
topic - the topic.partition - the partition.