File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
clients/src/main/java/org/apache/kafka/clients/consumer Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 239
239
* In <code>read_uncommitted</code> isolation level, the share group consumes all non-transactional and transactional
240
240
* records. The consumption is bounded by the high-water mark.
241
241
* <p>
242
- * In <code>read_committed</code> isolation level (not yet supported) , the share group only consumes non-transactional
243
- * records and committed transactional records. The set of records which are eligible to become in-flight records are
242
+ * In <code>read_committed</code> isolation level, the share group only consumes non-transactional records and
243
+ * committed transactional records. The set of records which are eligible to become in-flight records are
244
244
* non-transactional records and committed transactional records only. The consumption is bounded by the last stable
245
245
* offset, so an open transaction blocks the progress of the share group with read_committed isolation level.
246
246
*
@@ -497,7 +497,7 @@ public void acknowledge(ConsumerRecord<K, V> record) {
497
497
* <p>This method can only be used if the consumer is using <b>explicit acknowledgement</b>.
498
498
*
499
499
* @param record The record to acknowledge
500
- * @param type The acknowledgement type which indicates whether it was processed successfully
500
+ * @param type The acknowledge type which indicates whether it was processed successfully
501
501
*
502
502
* @throws IllegalStateException if the record is not waiting to be acknowledged, or the consumer is not using
503
503
* explicit acknowledgement
You can’t perform that action at this time.
0 commit comments