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 seek(java.lang.String topic, int partition, long offset)
topic
- the topic.partition
- the partition.offset
- the offset (absolute).