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: KAFKA-9194: Update documentation for replica.fetch.min.bytes config
Date Sun, 21 Jun 2020 10:16:06 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 199f375  KAFKA-9194: Update documentation for replica.fetch.min.bytes config
199f375 is described below

commit 199f375b546c201289d2b15084e0a95598093fe0
Author: sbellapu <sbellapu@visa.com>
AuthorDate: Sun Jun 21 15:43:34 2020 +0530

    KAFKA-9194: Update documentation for replica.fetch.min.bytes config
    
    Looks it is a typo, the actual key supposed to be this #replicaFetchWaitMaxTimeMs(replica.fetch.wait.max.ms)
instead of that the docs have this #replicaMaxWaitTimeMs
    
    Author: sbellapu <sbellapu@visa.com>
    Author: sbellapu <satishbabumsc@gmail.com>
    
    Reviewers: Matthias J. Sax <matthias@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>,
Manikumar Reddy <manikumar.reddy@gmail.com>
    
    Closes #8877 from satishbellapu/trunk
---
 core/src/main/scala/kafka/server/KafkaConfig.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala
index 544c17f..a8b54ad 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -782,7 +782,7 @@ object KafkaConfig {
     "<code>message.max.bytes</code> (broker config) or <code>max.message.bytes</code>
(topic config)."
   val ReplicaFetchWaitMaxMsDoc = "max wait time for each fetcher request issued by follower
replicas. This value should always be less than the " +
   "replica.lag.time.max.ms at all times to prevent frequent shrinking of ISR for low throughput
topics"
-  val ReplicaFetchMinBytesDoc = "Minimum bytes expected for each fetch response. If not enough
bytes, wait up to replicaMaxWaitTimeMs"
+  val ReplicaFetchMinBytesDoc = "Minimum bytes expected for each fetch response. If not enough
bytes, wait up to <code>replica.fetch.wait.max.ms</code> (broker config)."
   val ReplicaFetchResponseMaxBytesDoc = "Maximum bytes expected for the entire fetch response.
Records are fetched in batches, " +
     "and if the first record batch in the first non-empty partition of the fetch is larger
than this value, the record batch " +
     "will still be returned to ensure that progress can be made. As such, this is not an
absolute maximum. The maximum " +


Mime
View raw message