public final class Seek.Offset extends Object implements BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,org.apache.kafka.common.TopicPartition>
Modifier and Type | Method and Description |
---|---|
void |
accept(org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
org.apache.kafka.common.TopicPartition topicPartition) |
boolean |
equals(Object o) |
int |
hashCode() |
long |
offset() |
Seek |
seek() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
andThen
public long offset()
public Seek seek()
public void accept(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, org.apache.kafka.common.TopicPartition topicPartition)
accept
in interface BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,org.apache.kafka.common.TopicPartition>
Copyright © 2020 Red Hat. All rights reserved.