This is an automated email from the ASF dual-hosted git repository. rgoers pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/logging-log4j2.git
commit 3344202ce5492fcacf169656f1b3e816b51dca12 Author: Ralph Goers <[email protected]> AuthorDate: Sun Feb 9 13:52:59 2020 -0700 LOG4J2-2777 - Add retry count to Kafka Appender --- .../logging/log4j/kafka/appender/KafkaAppender.java | 15 +++++++++++++++ src/changes/changes.xml | 3 +++ 2 files changed, 18 insertions(+) diff --git a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaAppender.java b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaAppender.java index 6af669e..ec5e512 100644 --- a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaAppender.java +++ b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaAppender.java @@ -109,6 +109,21 @@ public final class KafkaAppender extends AbstractAppender { this.sendEventTimestamp = sendEventTimestamp; return asBuilder(); } + + public Integer getRetryCount() { + Integer intRetryCount = null; + try { + intRetryCount = Integer.valueOf(retryCount); + } catch (NumberFormatException e) { + + } + return intRetryCount; + } + + public B setRetryCount(final String retryCount) { + this.retryCount = retryCount; + return asBuilder(); + } } /** diff --git a/src/changes/changes.xml b/src/changes/changes.xml index 39b9382..c223445 100644 --- a/src/changes/changes.xml +++ b/src/changes/changes.xml @@ -166,6 +166,9 @@ </action> </release> <release version="2.13.1" date="2019-MM-DD" description="GA Release 2.13.1"> + <action issue="LOG4J2-2777" dev="rgoers" type="update" due-to="joongs4"> + Add a retry count attribute to the KafkaAppender. + </action> <action issue="LOG4J2-2776" dev="rgoers" type="fix" due-to="Christoph Kaser"> An error message in RollingFileAppender uses a placeholder for the name but does not specify the name argument in the logging call
