Repository: kafka Updated Branches: refs/heads/trunk b5401f291 -> d60e2ea58
MINOR: Fix logging message in `NetworkClient.poll` not to mention `producer` Author: Ismael Juma <[email protected]> Reviewers: Jun Rao <[email protected]> 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 <[email protected]> Authored: Thu Nov 12 07:20:10 2015 -0800 Committer: Jun Rao <[email protected]> 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
