You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by ma...@apache.org on 2016/03/07 01:54:50 UTC
[3/3] logging-log4j2 git commit: Add useful toString() on
KafkaAppender.
Add useful toString() on KafkaAppender.
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/ba18a929
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/ba18a929
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/ba18a929
Branch: refs/heads/master
Commit: ba18a929c14ca68d361dcd69227482f4f922cd1a
Parents: 7032e32
Author: Matt Sicker <bo...@gmail.com>
Authored: Sun Mar 6 18:54:39 2016 -0600
Committer: Matt Sicker <bo...@gmail.com>
Committed: Sun Mar 6 18:54:39 2016 -0600
----------------------------------------------------------------------
.../logging/log4j/core/appender/mom/kafka/KafkaAppender.java | 7 +++++++
.../logging/log4j/core/appender/mom/kafka/KafkaManager.java | 4 ++++
2 files changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/ba18a929/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppender.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppender.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppender.java
index 4162744..7743e57 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppender.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppender.java
@@ -102,4 +102,11 @@ public final class KafkaAppender extends AbstractAppender {
manager.release();
}
+ @Override
+ public String toString() {
+ return "KafkaAppender{" +
+ "name=" + getName() +
+ ", topic=" + manager.getTopic() +
+ '}';
+ }
}
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/ba18a929/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
index ca141b0..4e4a09c 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
@@ -86,4 +86,8 @@ public class KafkaManager extends AbstractManager {
producer = producerFactory.newKafkaProducer(config);
}
+ public String getTopic() {
+ return topic;
+ }
+
}