@@ -87,11 +87,11 @@ default void unregisterSeekCallback() {
8787 interface ConsumerSeekCallback {
8888
8989 /**
90- * When called from
90+ * Perform a seek operation. When called from
9191 * {@link ConsumerSeekAware#onPartitionsAssigned(Map, ConsumerSeekCallback)} or
9292 * from {@link ConsumerSeekAware#onIdleContainer(Map, ConsumerSeekCallback)}
9393 * perform the seek immediately on the consumer. When called from elsewhere,
94- * queue a seek operation to the consumer. The queued seek will occur after any
94+ * queue the seek operation to the consumer. The queued seek will occur after any
9595 * pending offset commits. The consumer must be currently assigned the specified
9696 * partition.
9797 * @param topic the topic.
@@ -101,11 +101,11 @@ interface ConsumerSeekCallback {
101101 void seek (String topic , int partition , long offset );
102102
103103 /**
104- * When called from
104+ * Perform a seek to beginning operation. When called from
105105 * {@link ConsumerSeekAware#onPartitionsAssigned(Map, ConsumerSeekCallback)} or
106106 * from {@link ConsumerSeekAware#onIdleContainer(Map, ConsumerSeekCallback)}
107107 * perform the seek immediately on the consumer. When called from elsewhere, queue
108- * a seekToBeginning operation to the consumer. The queued seek will occur after
108+ * the seek operation to the consumer. The queued seek will occur after
109109 * any pending offset commits. The consumer must be currently assigned the
110110 * specified partition.
111111 * @param topic the topic.
0 commit comments