You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2022/03/18 08:27:49 UTC

[kafka] branch 3.0 updated: MINOR: Fix `ConsumerConfig.ISOLATION_LEVEL_DOC` (#11915)

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 7c36205  MINOR: Fix `ConsumerConfig.ISOLATION_LEVEL_DOC` (#11915)
7c36205 is described below

commit 7c3620594ae5a8b59eea3e8c12f30c8a52571f94
Author: Jules Ivanic <gu...@users.noreply.github.com>
AuthorDate: Fri Mar 18 16:20:08 2022 +0800

    MINOR: Fix `ConsumerConfig.ISOLATION_LEVEL_DOC` (#11915)
    
    Reviewers: David Jacot <dj...@confluent.io>
---
 .../src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
index ca24c28..48f1ccb 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
@@ -312,7 +312,7 @@ public class ConsumerConfig extends AbstractConfig {
             " <code>read_committed</code> mode, consumer.poll() will only return messages up to the last stable offset (LSO), which is the one less than the offset of the first open transaction." +
             " In particular any messages appearing after messages belonging to ongoing transactions will be withheld until the relevant transaction has been completed. As a result, <code>read_committed</code>" +
             " consumers will not be able to read up to the high watermark when there are in flight transactions.</p><p> Further, when in <code>read_committed</code> the seekToEnd method will" +
-            " return the LSO";
+            " return the LSO</p>";
 
     public static final String DEFAULT_ISOLATION_LEVEL = IsolationLevel.READ_UNCOMMITTED.toString().toLowerCase(Locale.ROOT);