1
resposta

Criar o o broker 2

Olá, não estou conseguindo rodar o broker 2, fiz conforme a aula e no meu não está dando certo, ele não sobe, da essa mensagem de erro

[2021-07-14 17:00:49,421] ERROR [KafkaServer id=3] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) org.apache.kafka.common.KafkaException: Socket server failed to bind to 0.0.0.0:9092: Address already in use: bind. at kafka.network.Acceptor.openServerSocket(SocketServer.scala:667) at kafka.network.Acceptor.(SocketServer.scala:560) at kafka.network.SocketServer.createAcceptor(SocketServer.scala:288) at kafka.network.SocketServer.$anonfun$createDataPlaneAcceptorsAndProcessors$1(SocketServer.scala:261) at kafka.network.SocketServer.$anonfun$createDataPlaneAcceptorsAndProcessors$1$adapted(SocketServer.scala:259) at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:563) at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:561) at scala.collection.AbstractIterable.foreach(Iterable.scala:919) at kafka.network.SocketServer.createDataPlaneAcceptorsAndProcessors(SocketServer.scala:259) at kafka.network.SocketServer.startup(SocketServer.scala:131) at kafka.server.KafkaServer.startup(KafkaServer.scala:285) at kafka.Kafka$.main(Kafka.scala:109) at kafka.Kafka.main(Kafka.scala) Caused by: java.net.BindException: Address already in use: bind at java.base/sun.nio.ch.Net.bind0(Native Method) at java.base/sun.nio.ch.Net.bind(Net.java:455) at java.base/sun.nio.ch.Net.bind(Net.java:447) at java.base/sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:227) at java.base/sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:80) at java.base/sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:73) at kafka.network.Acceptor.openServerSocket(SocketServer.scala:663) ... 12 more

como faço pra resolver?
1 resposta

Acho que vc precisa acessar o arquivo de configuração e alterar a porta, pois a 9092 já é usada no broker 1