You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2015/11/12 16:20:18 UTC

kafka git commit: MINOR: Fix logging message in `NetworkClient.poll` not to mention `producer`

Repository: kafka
Updated Branches:
  refs/heads/trunk b5401f291 -> d60e2ea58


MINOR: Fix logging message in `NetworkClient.poll` not to mention `producer`

Author: Ismael Juma <is...@juma.me.uk>

Reviewers: Jun Rao <ju...@gmail.com>

Closes #507 from ijuma/fix-error-message-in-network-client-poll


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d60e2ea5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d60e2ea5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d60e2ea5

Branch: refs/heads/trunk
Commit: d60e2ea581289a02efcef3b692bbb043fbdf3199
Parents: b5401f2
Author: Ismael Juma <is...@juma.me.uk>
Authored: Thu Nov 12 07:20:10 2015 -0800
Committer: Jun Rao <ju...@gmail.com>
Committed: Thu Nov 12 07:20:10 2015 -0800

----------------------------------------------------------------------
 clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d60e2ea5/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
index 6c8853d..52db61a 100644
--- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -269,7 +269,7 @@ public class NetworkClient implements KafkaClient {
         try {
             this.selector.poll(Utils.min(timeout, metadataTimeout, requestTimeoutMs));
         } catch (IOException e) {
-            log.error("Unexpected error during I/O in producer network thread", e);
+            log.error("Unexpected error during I/O", e);
         }
 
         // process completed actions