commit c03310dfbd09806944ad512e1933ff90aab969c3
author Yijie Shen <henry.yijieshen@gmail.com> Fri Mar 27 19:31:06 2020 +0800
committer GitHub <noreply@github.com> Fri Mar 27 19:31:06 2020 +0800
tree 443ee716b3580763ab6d6476688447e447504892
parent 72a71f2d903127c65e426db9d329b63d0c87e32f

Number of placeholder doesn't match number of arguments in logging (#6618)

pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java

diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java b/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
index f264bf1..7d6e146 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
@@ -268,7 +268,7 @@
                 try {
                     producer.close();
                 } catch (PulsarClientException e) {
-                    log.warn("Failed to close producer for {}", topic, e.getMessage());
+                    log.warn("Failed to close producer for {}: {}", topic, e.getMessage());
                 }
             });
         }
@@ -276,7 +276,7 @@
             try {
                 client.close();
             } catch (PulsarClientException e) {
-                log.warn("Failed to close pulsar-client {}", e.getMessage());
+                log.warn("Failed to close pulsar-client", e);
             }
         }
     }