我的卡夫卡不能启动成功

来源: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的防火墙来开放端口。

1
0

Allen

2020-05-21

两个方面, 一个是ip地址改成可以访问的ip, 另一个是把防火墙和安全的9092端口开放

1
0

Kafka多维度系统精讲,从入门到实战开发

系统讲解Kafka,实战结合,让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程