KAFKA-2571; KafkaLog4jAppender dies while specifying acks config

Author: Ashish Singh <[email protected]>

Reviewers: Ewen Cheslack-Postava, Gwen Shapira

Closes apache#231 from SinghAsDev/KAFKA-2571

Author: Ashish Singh

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

@@ -117,7 +117,7 @@ public void activateOptions() {
         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);