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/LOG4J2-89 Commit: 8ef2ab8aea78fbf7d37502606a2768616a9b8e0d Parents: 9ad3603 Author: Mikael Ståldal <[email protected]> Authored: Tue Nov 10 17:34:26 2015 +0100 Committer: Ralph Goers <[email protected]> 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);
