commit 00d440d61d36b509624afdf692c91f28809e8e84
author Arturo Bernal <arturobernalg@gmail.com> Thu Jun 24 17:21:12 2021 +0200
committer GitHub <noreply@github.com> Thu Jun 24 17:21:12 2021 +0200
tree 72bf31d71fa220d0fbaa91ac2f31ace9a29b83d7
parent c91e5a26124dd7b7883e6511b5ca569b3bbba5f2

Replace anonymous classes with lambda expressions. (#526)

log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java

diff --git a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
index db03167..5b5a543 100644
--- a/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
+++ b/log4j-kafka/src/main/java/org/apache/logging/log4j/kafka/appender/KafkaManager.java
@@ -101,14 +101,11 @@
     private void closeProducer(final long timeout, final TimeUnit timeUnit) {
         if (producer != null) {
             // This thread is a workaround for this Kafka issue: https://issues.apache.org/jira/browse/KAFKA-1660
-           final Thread closeThread = new Log4jThread(new Runnable() {
-                @Override
-                public void run() {
-                    if (producer != null) {
-                        producer.close();
-                    }
-                }
-            }, "KafkaManager-CloseThread");
+           final Thread closeThread = new Log4jThread(() -> {
+               if (producer != null) {
+                   producer.close();
+               }
+           }, "KafkaManager-CloseThread");
             closeThread.setDaemon(true); // avoid blocking JVM shutdown
             closeThread.start();
             try {
@@ -140,12 +137,9 @@
                 final Future<RecordMetadata> response = producer.send(newRecord);
                 response.get(timeoutMillis, TimeUnit.MILLISECONDS);
             } else {
-                producer.send(newRecord, new Callback() {
-                    @Override
-                    public void onCompletion(final RecordMetadata metadata, final Exception e) {
-                        if (e != null) {
-                            LOGGER.error("Unable to write to Kafka in appender [" + getName() + "]", e);
-                        }
+                producer.send(newRecord, (metadata, e) -> {
+                    if (e != null) {
+                        LOGGER.error("Unable to write to Kafka in appender [" + getName() + "]", e);
                     }
                 });
             }