You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/02/25 21:36:00 UTC
[jira] [Commented] (KAFKA-3050) Space in the value for "host.name"
causes "Unresolved address"
[ https://issues.apache.org/jira/browse/KAFKA-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16376259#comment-16376259 ]
ASF GitHub Bot commented on KAFKA-3050:
---------------------------------------
hachikuji closed pull request #777: KAFKA-3050: Acceptor allows hostnames surrounded by whitespaces
URL: https://github.com/apache/kafka/pull/777
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
index c3ecd750c21..3f876441744 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -297,7 +297,7 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
if(host == null || host.trim.isEmpty)
new InetSocketAddress(port)
else
- new InetSocketAddress(host, port)
+ new InetSocketAddress(host.trim, port)
val serverChannel = ServerSocketChannel.open()
serverChannel.configureBlocking(false)
serverChannel.socket().setReceiveBufferSize(recvBufferSize)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> Space in the value for "host.name" causes "Unresolved address"
> --------------------------------------------------------------
>
> Key: KAFKA-3050
> URL: https://issues.apache.org/jira/browse/KAFKA-3050
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8.2.1
> Reporter: Navin Markandeya
> Priority: Major
> Labels: newbie
> Fix For: 0.9.0.0
>
>
> In {{<KAFKA_HOME>/config/server.properties}}, after updating the {{host.name}} to a value with a space after "localhost", received
> {code}
> [2015-12-30 11:13:43,014] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
> kafka.common.KafkaException: Socket server failed to bind to localhost :9092: Unresolved address.
> at kafka.network.Acceptor.openServerSocket(SocketServer.scala:260)
> at kafka.network.Acceptor.<init>(SocketServer.scala:205)
> at kafka.network.SocketServer.startup(SocketServer.scala:86)
> at kafka.server.KafkaServer.startup(KafkaServer.scala:99)
> at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:29)
> at kafka.Kafka$.main(Kafka.scala:46)
> at kafka.Kafka.main(Kafka.scala)
> Caused by: java.net.SocketException: Unresolved address
> at sun.nio.ch.Net.translateToSocketException(Net.java:131)
> at sun.nio.ch.Net.translateException(Net.java:157)
> at sun.nio.ch.Net.translateException(Net.java:163)
> at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:76)
> at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67)
> at kafka.network.Acceptor.openServerSocket(SocketServer.scala:256)
> ... 6 more
> Caused by: java.nio.channels.UnresolvedAddressException
> at sun.nio.ch.Net.checkAddress(Net.java:101)
> at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:218)
> at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
> ... 8 more
> {code}
> I am running {{kafka_2.9.1-0.8.2.2}} on Centos6.5 with Java8
> {code}
> java version "1.8.0_60"
> Java(TM) SE Runtime Environment (build 1.8.0_60-b27)
> Java HotSpot(TM) 64-Bit Server VM (build 25.60-b23, mixed mode)
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)