kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maniku...@apache.org
Subject [kafka] branch trunk updated: MINOR: Remove an unnecessary character from broker's startup log
Date Thu, 25 Apr 2019 15:06:19 GMT
This is an automated email from the ASF dual-hosted git repository.

manikumar 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 25ea924  MINOR: Remove an unnecessary character from broker's startup log
25ea924 is described below

commit 25ea9246be749b9f1bafda56fb547871eae557c0
Author: Kengo Seki <sekikn@apache.org>
AuthorDate: Thu Apr 25 20:35:50 2019 +0530

    MINOR: Remove an unnecessary character from broker's startup log
    
    Author: Kengo Seki <sekikn@apache.org>
    
    Reviewers: Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
    
    Closes #6628 from sekikn/remove-unnecessary-character
---
 core/src/main/scala/kafka/network/SocketServer.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
index e06cee7..1f4f1b6 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -599,7 +599,7 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
 
     try {
       serverChannel.socket.bind(socketAddress)
-      info(s"Awaiting socket connections on s${socketAddress.getHostString}:${serverChannel.socket.getLocalPort}.")
+      info(s"Awaiting socket connections on ${socketAddress.getHostString}:${serverChannel.socket.getLocalPort}.")
     } catch {
       case e: SocketException =>
         throw new KafkaException(s"Socket server failed to bind to ${socketAddress.getHostString}:$port:
${e.getMessage}.", e)


Mime
View raw message