kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rha...@apache.org
Subject [kafka] branch trunk updated: improve some logging statements (#6078)
Date Mon, 04 Mar 2019 23:57:54 GMT
This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new d930e5d  improve some logging statements (#6078)
d930e5d is described below

commit d930e5d3d85697a9a851ab2de98e7d8ca567d001
Author: lzh3636 <lzh9410@gmail.com>
AuthorDate: Mon Mar 4 18:57:45 2019 -0500

    improve some logging statements (#6078)
    
    Reviewers: Matthias J. Sax <matthias@confluent.io>, Randall Hauch <rhauch@gmail.com>
---
 .../org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java   | 2 +-
 .../java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java  | 2 +-
 .../apache/kafka/streams/processor/internals/GlobalStreamThread.java    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
index 95b53e5..172c9b2 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
@@ -318,7 +318,7 @@ public class StandaloneHerder extends AbstractHerder {
 
     private void updateConnectorTasks(String connName) {
         if (!worker.isRunning(connName)) {
-            log.info("Skipping reconfiguration of connector {} since it is not running",
connName);
+            log.info("Skipping update of connector {} since it is not running", connName);
             return;
         }
 
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
index 6710808..fee1010 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
@@ -340,7 +340,7 @@ public class KafkaStatusBackingStore implements StatusBackingStore {
         try {
             SchemaAndValue schemaAndValue = converter.toConnectData(topic, data);
             if (!(schemaAndValue.value() instanceof Map)) {
-                log.error("Invalid connector status type {}", schemaAndValue.value().getClass());
+                log.error("Invalid task status type {}", schemaAndValue.value().getClass());
                 return null;
             }
             @SuppressWarnings("unchecked")
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java
index d91aedf..0b6539a 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java
@@ -258,7 +258,7 @@ public class GlobalStreamThread extends Thread {
             } catch (final RuntimeException e) {
                 // just log an error if the consumer throws an exception during close
                 // so we can always attempt to close the state stores.
-                log.error("Failed to close consumer due to the following error:", e);
+                log.error("Failed to close global consumer due to the following error:",
e);
             }
 
             stateMaintainer.close();


Mime
View raw message