You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by mi...@apache.org on 2017/10/13 19:38:36 UTC
[3/4] logging-log4j2 git commit: LOG4J2-2062 Fix formatting
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 <mi...@staldal.nu>
Authored: Fri Oct 13 21:36:29 2017 +0200
Committer: Mikael Ståldal <mi...@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);