LOG4J2-2062 Fix formatting
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/b7eca4eb Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/b7eca4eb Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/b7eca4eb Branch: refs/heads/master Commit: b7eca4eb74cfcb832fa8d28202ea53b0acaa9ca3 Parents: ea3a5bd Author: Mikael Ståldal <mik...@staldal.nu> Authored: Fri Oct 13 21:36:29 2017 +0200 Committer: Mikael Ståldal <mik...@staldal.nu> Committed: Fri Oct 13 21:36:29 2017 +0200 ---------------------------------------------------------------------- .../logging/log4j/core/appender/mom/kafka/KafkaManager.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/b7eca4eb/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java index 7c3f1cd..1051561 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java @@ -60,12 +60,9 @@ public class KafkaManager extends AbstractManager { config.setProperty("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer"); config.setProperty("batch.size", "0"); for (final Property property : properties) { - config.setProperty(property.getName(), property.getValue()); } - this.key = (key != null ) ? key.getBytes(StandardCharsets.UTF_8) : null ; - this.timeoutMillis = Integer.parseInt(config.getProperty("timeout.ms", DEFAULT_TIMEOUT_MILLIS)); } @@ -103,7 +100,6 @@ public class KafkaManager extends AbstractManager { public void send(final byte[] msg) throws ExecutionException, InterruptedException, TimeoutException { if (producer != null) { - final ProducerRecord<byte[], byte[]> newRecord = new ProducerRecord<>(topic, key, msg); if (syncSend) { final Future<RecordMetadata> response = producer.send(newRecord);
