kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maniku...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fixes AK config typos (#7046)
Date Tue, 09 Jul 2019 08:55:53 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 3bb126d  MINOR: Fixes AK config typos (#7046)
3bb126d is described below

commit 3bb126dfbf7534135bfe73b5dbc9272b6acd351f
Author: Joel Hamill <11722533+joel-hamill@users.noreply.github.com>
AuthorDate: Tue Jul 9 02:55:38 2019 -0600

    MINOR: Fixes AK config typos (#7046)
---
 clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java | 2 +-
 clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
index d8428a7..3b32e32 100644
--- a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
+++ b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
@@ -105,7 +105,7 @@ public class CommonClientConfigs {
     public static final String GROUP_ID_DOC = "A unique string that identifies the consumer
group this consumer belongs to. This property is required if the consumer uses either the
group management functionality by using <code>subscribe(topic)</code> or the Kafka-based
offset management strategy.";
 
     public static final String GROUP_INSTANCE_ID_CONFIG = "group.instance.id";
-    public static final String GROUP_INSTANCE_ID_DOC = "A unique identifier of the consumer
instance provided by end user. " +
+    public static final String GROUP_INSTANCE_ID_DOC = "A unique identifier of the consumer
instance provided by the end user. " +
             "Only non-empty strings are permitted. If set, the consumer is treated as a static
member, " +
             "which means that only one instance with this ID is allowed in the consumer group
at any time. " +
             "This can be used in combination with a larger session timeout to avoid group
rebalances caused by transient unavailability " +
diff --git a/clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java b/clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java
index f912cd2..24f8a5a 100755
--- a/clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java
+++ b/clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java
@@ -116,7 +116,7 @@ public class TopicConfig {
         "the log by duplicates (at 50% at most 50% of the log could be duplicates). A " +
         "higher ratio will mean fewer, more efficient cleanings but will mean more wasted
" +
         "space in the log. If the " + MAX_COMPACTION_LAG_MS_CONFIG + " or the " + MIN_COMPACTION_LAG_MS_CONFIG
+
-        " configurations are also specified, then the log compactor considers the log eligible
for compaction " +
+        " configurations are also specified, then the log compactor considers the log to
be eligible for compaction " +
         "as soon as either: (i) the dirty ratio threshold has been met and the log has had
dirty (uncompacted) " +
         "records for at least the " + MIN_COMPACTION_LAG_MS_CONFIG + " duration, or (ii)
if the log has had " +
         "dirty (uncompacted) records for at most the " + MAX_COMPACTION_LAG_MS_CONFIG + "
period.";


Mime
View raw message