File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
spring-kafka/src/main/java/org/springframework/kafka/support Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -52,14 +52,16 @@ default void nack(Duration sleep) {
52
52
}
53
53
54
54
/**
55
- * Acknowledge the record at an index in the batch - commit the offset(s) of records in the batch
56
- * up to and including the index. Requires {@link AckMode#MANUAL_IMMEDIATE}. The index must be
57
- * greater than any previous partial batch acknowledgment index.
55
+ * Acknowledge the record at an index in the batch - commit the offset(s) of records
56
+ * in the batch up to and including the index. Requires
57
+ * {@link AckMode#MANUAL_IMMEDIATE}. The index must be greater than any previous
58
+ * partial batch acknowledgment index for this batch and in the range of the record
59
+ * list. This method must be called on the listener thread.
58
60
* @param index the index of the record to acknowledge.
59
61
* @since 3.0.10
60
62
*/
61
63
default void acknowledge (int index ) {
62
- throw new UnsupportedOperationException ("nack(sleep ) is not supported by this Acknowledgment" );
64
+ throw new UnsupportedOperationException ("ack(index ) is not supported by this Acknowledgment" );
63
65
}
64
66
65
67
/**
You can’t perform that action at this time.
0 commit comments