This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new e323f4b MINOR: Fixing log format typo (#7219)
e323f4b is described below
commit e323f4be5deceb1e6f48a7f179e0447000e8e6a4
Author: Cheng Pan <[email protected]>
AuthorDate: Sat Aug 17 10:58:43 2019 -0500
MINOR: Fixing log format typo (#7219)
Reviewers: Manikumar Reddy <[email protected]>
---
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
b/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
index cdd7513..1d71ea1 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
@@ -63,7 +63,7 @@ public final class ClientUtils {
String resolvedCanonicalName =
inetAddress.getCanonicalHostName();
InetSocketAddress address = new
InetSocketAddress(resolvedCanonicalName, port);
if (address.isUnresolved()) {
- log.warn("Couldn't resolve server {} from {}
as DNS resolution of the canonical hostname [} failed for {}", url,
CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, resolvedCanonicalName, host);
+ log.warn("Couldn't resolve server {} from {}
as DNS resolution of the canonical hostname {} failed for {}", url,
CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, resolvedCanonicalName, host);
} else {
addresses.add(address);
}