我的卡夫卡不能启动成功
来源:3-6 Kafka基本概念及使用演示

慕瓜7568750
2020-05-20
在log里面说不能bind我的云主机ip(我用x代替了我的地址),之前在配置kafka的时候我把监听的host改成了我的云主机公共ip,是不是不该这样改?
org.apache.kafka.common.KafkaException: Socket server failed to bind to xx.xx.xx.126:9092: Cannot assign requested address.
at kafka.network.Acceptor.openServerSocket(SocketServer.scala:605)
at kafka.network.Acceptor.(SocketServer.scala:481)
at kafka.network.SocketServer.createAcceptor(SocketServer.scala:244)
at kafka.network.SocketServer.anonfunanonfunanonfuncreateDataPlaneAcceptorsAndProcessors1(SocketServer.scala:213)atkafka.network.SocketServer.1(SocketServer.scala:213)
at kafka.network.SocketServer.1(SocketServer.scala:213)atkafka.network.SocketServer.anonfun$createDataPlaneAcceptorsAndProcessors111adapted(SocketServer.scala:211)
at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:55)atscala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)atkafka.network.SocketServer.createDataPlaneAcceptorsAndProcessors(SocketServer.scala:211)atkafka.network.SocketServer.startup(SocketServer.scala:122)atkafka.server.KafkaServer.startup(KafkaServer.scala:266)atkafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)atkafka.Kafka(ResizableArray.scala:55)
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
at kafka.network.SocketServer.createDataPlaneAcceptorsAndProcessors(SocketServer.scala:211)
at kafka.network.SocketServer.startup(SocketServer.scala:122)
at kafka.server.KafkaServer.startup(KafkaServer.scala:266)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
at kafka.Kafka(ResizableArray.scala:55)atscala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)atkafka.network.SocketServer.createDataPlaneAcceptorsAndProcessors(SocketServer.scala:211)atkafka.network.SocketServer.startup(SocketServer.scala:122)atkafka.server.KafkaServer.startup(KafkaServer.scala:266)atkafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)atkafka.Kafka.main(Kafka.scala:82)
at kafka.Kafka.main(Kafka.scala)
Caused by: java.net.BindException: Cannot assign requested address
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67)
at kafka.network.Acceptor.openServerSocket(SocketServer.scala:601)
2回答
-
慕数据3866775
2020-05-28
zookeeper和kafka在同一台机器上,你可以试下把listener和advertised.listeners改成云主机内部ip的地址,内部流量总是可以访问,如果用的是外部ip,应该需要设置inboud和outboud的防火墙来开放端口。
10 -
Allen
2020-05-21
两个方面, 一个是ip地址改成可以访问的ip, 另一个是把防火墙和安全的9092端口开放
10
相似问题