Repository: logging-log4j2 Updated Branches: refs/heads/master 6d360ed50 -> 3390ebe84
LOG4J2-1733 Test Kafka async send Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/daf7b471 Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/daf7b471 Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/daf7b471 Branch: refs/heads/master Commit: daf7b4714e2cd145250c32805f2f11bd586c6a75 Parents: 6d360ed Author: Mikael Ståldal <[email protected]> Authored: Mon Jan 23 17:12:07 2017 +0100 Committer: Mikael Ståldal <[email protected]> Committed: Mon Jan 23 17:12:07 2017 +0100 ---------------------------------------------------------------------- .../core/appender/mom/kafka/KafkaAppenderTest.java | 13 +++++++++++++ log4j-core/src/test/resources/KafkaAppenderTest.xml | 5 +++++ 2 files changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/daf7b471/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java index aed7723..4cac0db 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java @@ -135,6 +135,19 @@ public class KafkaAppenderTest { assertEquals(LOG_MESSAGE, deserializeLogEvent(item.value()).getMessage().getFormattedMessage()); } + @Test + public void testAsyncAppend() throws Exception { + final Appender appender = ctx.getRequiredAppender("AsyncKafkaAppender"); + appender.append(createLogEvent()); + final List<ProducerRecord<byte[], byte[]>> history = kafka.history(); + assertEquals(1, history.size()); + final ProducerRecord<byte[], byte[]> item = history.get(0); + assertNotNull(item); + assertEquals(TOPIC_NAME, item.topic()); + assertNull(item.key()); + assertEquals(LOG_MESSAGE, new String(item.value(), StandardCharsets.UTF_8)); + } + private LogEvent deserializeLogEvent(final byte[] data) throws IOException, ClassNotFoundException { final ByteArrayInputStream bis = new ByteArrayInputStream(data); try (ObjectInput ois = new ObjectInputStream(bis)) { http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/daf7b471/log4j-core/src/test/resources/KafkaAppenderTest.xml ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/resources/KafkaAppenderTest.xml b/log4j-core/src/test/resources/KafkaAppenderTest.xml index 6b256ad..dda8271 100644 --- a/log4j-core/src/test/resources/KafkaAppenderTest.xml +++ b/log4j-core/src/test/resources/KafkaAppenderTest.xml @@ -31,12 +31,17 @@ <Property name="bootstrap.servers">localhost:9092</Property> <Property name="timeout.ms">1000</Property> </Kafka> + <Kafka name="AsyncKafkaAppender" topic="kafka-topic"> + <Property name="bootstrap.servers">localhost:9092</Property> + <Property name="syncSend">false</Property> + </Kafka> </Appenders> <Loggers> <Root level="info"> <AppenderRef ref="KafkaAppender"/> <AppenderRef ref="KafkaAppenderWithLayout"/> <AppenderRef ref="KafkaAppenderWithSerializedLayout"/> + <AppenderRef ref="AsyncKafkaAppender"/> </Root> </Loggers> </Configuration> \ No newline at end of file
