You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by rg...@apache.org on 2015/11/21 05:48:45 UTC
[19/42] logging-log4j2 git commit: Use StringEncoder for encoding
String to byte[]
Use StringEncoder for encoding String to byte[]
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/8ef2ab8a
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/8ef2ab8a
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/8ef2ab8a
Branch: refs/heads/master
Commit: 8ef2ab8aea78fbf7d37502606a2768616a9b8e0d
Parents: 9ad3603
Author: Mikael Ståldal <mi...@magine.com>
Authored: Tue Nov 10 17:34:26 2015 +0100
Committer: Ralph Goers <rg...@apache.org>
Committed: Fri Nov 20 17:39:21 2015 -0700
----------------------------------------------------------------------
.../logging/log4j/core/appender/mom/kafka/KafkaAppender.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/8ef2ab8a/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 3763c5e..633faf3 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
@@ -31,6 +31,7 @@ import org.apache.logging.log4j.core.config.plugins.PluginAttribute;
import org.apache.logging.log4j.core.config.plugins.PluginElement;
import org.apache.logging.log4j.core.config.plugins.PluginFactory;
import org.apache.logging.log4j.core.config.plugins.validation.constraints.Required;
+import org.apache.logging.log4j.core.util.StringEncoder;
/**
* Sends log events to an Apache Kafka topic.
@@ -70,7 +71,7 @@ public final class KafkaAppender extends AbstractAppender {
if (getLayout() != null) {
manager.send(getLayout().toByteArray(event));
} else {
- manager.send(event.getMessage().getFormattedMessage().getBytes(StandardCharsets.UTF_8));
+ manager.send(StringEncoder.toBytes(event.getMessage().getFormattedMessage(), StandardCharsets.UTF_8));
}
} catch (final Exception e) {
LOGGER.error("Unable to write to Kafka [{}] for appender [{}].", manager.getName(), getName(), e);