root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Ashish Singh 2015-09-24 19:16:28 -07:00 committed by Gwen Shapira
parent 48b4d6938d
commit 18d370124b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java
View File

@ -117,7 +117,7 @@ public class KafkaLog4jAppender extends AppenderSkeleton {
if (compressionType != null) if (compressionType != null)
props.put(COMPRESSION_TYPE_CONFIG, compressionType); props.put(COMPRESSION_TYPE_CONFIG, compressionType);
if (requiredNumAcks != Integer.MAX_VALUE) if (requiredNumAcks != Integer.MAX_VALUE)
props.put(ACKS_CONFIG, requiredNumAcks); props.put(ACKS_CONFIG, Integer.toString(requiredNumAcks));
if (retries > 0) if (retries > 0)
props.put(RETRIES_CONFIG, retries); props.put(RETRIES_CONFIG, retries);