kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: KAFKA-2571; KafkaLog4jAppender dies while specifying acks config
Date Fri, 25 Sep 2015 02:16:34 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 48b4d6938 -> 18d370124


KAFKA-2571; KafkaLog4jAppender dies while specifying acks config

Author: Ashish Singh <asingh@cloudera.com>

Reviewers: Ewen Cheslack-Postava, Gwen Shapira

Closes #231 from SinghAsDev/KAFKA-2571


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/18d37012
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/18d37012
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/18d37012

Branch: refs/heads/trunk
Commit: 18d370124b51a97eb0522c220eb0ca619e315c6a
Parents: 48b4d69
Author: Ashish Singh <asingh@cloudera.com>
Authored: Thu Sep 24 19:16:28 2015 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Thu Sep 24 19:16:28 2015 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/18d37012/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
----------------------------------------------------------------------
diff --git a/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
b/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
index 628ff53..2baef06 100644
--- a/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
+++ b/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
@@ -117,7 +117,7 @@ public class KafkaLog4jAppender extends AppenderSkeleton {
         if (compressionType != null)
             props.put(COMPRESSION_TYPE_CONFIG, compressionType);
         if (requiredNumAcks != Integer.MAX_VALUE)
-            props.put(ACKS_CONFIG, requiredNumAcks);
+            props.put(ACKS_CONFIG, Integer.toString(requiredNumAcks));
         if (retries > 0)
             props.put(RETRIES_CONFIG, retries);
 


Mime
View raw message