This is an automated email from the ASF dual-hosted git repository.
vy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/logging-log4j2.git
The following commit(s) were added to refs/heads/master by this push:
new 469edb0 LOG4J2-3175 Avoid KafkaManager override when topics differ.
(#590)
469edb0 is described below
commit 469edb07040e58b0a6250f5fa3476ce469b047bb
Author: Volkan Yazıcı <[email protected]>
AuthorDate: Mon Oct 18 18:58:40 2021 +0200
LOG4J2-3175 Avoid KafkaManager override when topics differ. (#590)
---
.../java/org/apache/logging/log4j/kafka/appender/KafkaManager.java | 1 +
src/changes/changes.xml | 3 +++
2 files changed, 4 insertions(+)
diff --git
a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
index 5b5a543..e0cb671 100644
---
a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
+++
b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
@@ -160,6 +160,7 @@ public class KafkaManager extends AbstractManager {
final boolean syncSend, final boolean sendTimestamp, final
Property[] properties, final String key,
final String retryCount) {
StringBuilder sb = new StringBuilder(name);
+ sb.append(" ").append(topic).append(" ").append(syncSend + "");
for (Property prop: properties) {
sb.append("
").append(prop.getName()).append("=").append(prop.getValue());
}
diff --git a/src/changes/changes.xml b/src/changes/changes.xml
index 69827c3..09d6052 100644
--- a/src/changes/changes.xml
+++ b/src/changes/changes.xml
@@ -237,6 +237,9 @@
based on performance improvements in modern Java releases.
</action>
<!-- FIXES -->
+ <action issue="LOG4J2-3175" dev="vy" type="fix" due-to="wuqian0808">
+ Avoid KafkaManager override when topics differ.
+ </action>
<action issue="LOG4J2-3160" dev="vy" type="fix" due-to="Lars Bohl">
Fix documentation on how to toggle log4j2.debug system property.
</action>