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/04a714cc Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/04a714cc Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/04a714cc Branch: refs/heads/LOG4J-1181 Commit: 04a714cc67ec3db534b85fac1d4a3ea699002e0a Parents: 90d82d2 Author: Mikael Ståldal <[email protected]> Authored: Tue Nov 10 17:34:26 2015 +0100 Committer: Mikael Ståldal <[email protected]> Committed: Tue Nov 10 17:34:26 2015 +0100 ---------------------------------------------------------------------- .../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/04a714cc/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);
