[kafka] branch 1.1 updated: MINOR: Fix incorrect references to the max transaction timeout config (#4664)

[jgus]

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

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


The following commit(s) were added to refs/heads/1.1 by this push:
     new 40b913d  MINOR: Fix incorrect references to the max transaction 
timeout config (#4664)
40b913d is described below

commit 40b913d085f6863d96778b3f2bddb3437404a1cc
Author: wushujames <jylch...@yahoo.com>
AuthorDate: Thu Mar 8 10:28:20 2018 -0800

    MINOR: Fix incorrect references to the max transaction timeout config 
(#4664)
---
 .../src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java | 2 +-
 .../java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java | 2 +-
 clients/src/main/java/org/apache/kafka/common/protocol/Errors.java      | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java 
b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
index 6428dc4..becbef6 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
@@ -212,7 +212,7 @@ public class ProducerConfig extends AbstractConfig {
     /** <code> transaction.timeout.ms </code> */
     public static final String TRANSACTION_TIMEOUT_CONFIG = 
"transaction.timeout.ms";
     public static final String TRANSACTION_TIMEOUT_DOC = "The maximum amount 
of time in ms that the transaction coordinator will wait for a transaction 
status update from the producer before proactively aborting the ongoing 
transaction." +
-            "If this value is larger than the max.transaction.timeout.ms 
setting in the broker, the request will fail with a `InvalidTransactionTimeout` 
error.";
+            "If this value is larger than the transaction.max.timeout.ms 
setting in the broker, the request will fail with a `InvalidTransactionTimeout` 
error.";
 
     /** <code> transactional.id </code> */
     public static final String TRANSACTIONAL_ID_CONFIG = "transactional.id";
diff --git 
a/clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java
 
b/clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java
index c751bc4..f16af66 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java
@@ -18,7 +18,7 @@ package org.apache.kafka.common.errors;
 
 /**
  * The transaction coordinator returns this error code if the timeout received 
via the InitProducerIdRequest is larger than
- * the `max.transaction.timeout.ms` config value.
+ * the `transaction.max.timeout.ms` config value.
  */
 public class InvalidTxnTimeoutException extends ApiException {
     private static final long serialVersionUID = 1L;
diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java 
b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
index 4b44c18..031c9a9 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
@@ -474,7 +474,7 @@ public enum Errors {
             }
         }),
     INVALID_TRANSACTION_TIMEOUT(50, "The transaction timeout is larger than 
the maximum value allowed by " +
-                "the broker (as configured by max.transaction.timeout.ms).",
+                "the broker (as configured by transaction.max.timeout.ms).",
         new ApiExceptionBuilder() {
             @Override
             public ApiException build(String message) {

-- 
To stop receiving notification emails like this one, please contact
j...@apache.org.