Crashes again. [2017-09-11 18:26:44,386] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.common.KafkaException: Socket server failed to bind to hidden_ip:55091: Cannot assign requested address.
Maybe I can better clarify: This broker is setup on a remote node. The ip:port of this node are private so the cluster manager set a proxy to redirect requests to the private ip:port The hidden_ip:55091 I used actually are the public ip:port I use to access to the node which is then translated in the private ip:port in the proxy. Therefore I set advertised.listeners=PLAINTEXT://public_ip:55091 <plaintext://public_ip:55091> while listeners was commented in order to use the default value. Clearly I’m overwriting the errors with the word “hidden_ip" > On 11 Sep 2017, at 18:06, M. Manna <manme...@gmail.com> wrote: > > Could you try with the following: > > listeners=PLAINTEXT:hidden_ip:55091 > advertised.listeners=PLAINTEXT://localhost:55091 > listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL > > "Until some weeks ago everything worked fine" - means you have accidentaly > changed something. > > On 11 September 2017 at 16:44, Andrea Giordano < > andrea.giordano....@gmail.com> wrote: > >> Hi, >> I set on a ubuntu node of a cluster a kafka 0.11.0.0 instance. Until some >> weeks ago everything worked fine, today I'm trying to starting it and I >> obtain this error after the boot: >> >> [2017-09-11 16:21:13,894] INFO [Kafka Server 0], started >> (kafka.server.KafkaServer) >> [2017-09-11 16:21:18,998] WARN Connection to node 0 could not be >> established. Broker may not be available. (org.apache.kafka.clients. >> NetworkClient) >> [2017-09-11 16:21:21,991] WARN Connection to node 0 could not be >> established. Broker may not be available. (org.apache.kafka.clients. >> NetworkClient) >> ... and so on... >> My server.properties: >> >> ############################# Server Basics ############################# >> >> # The id of the broker. This must be set to a unique integer for each >> broker. >> broker.id=0 >> >> # Switch to enable topic deletion or not, default value is false >> delete.topic.enable=true >> >> ############################# Socket Server Settings >> ##########################$ >> >> # The address the socket server listens on. It will get the value returned >> from >> # java.net.InetAddress.getCanonicalHostName() if not configured. >> # FORMAT: >> # listeners = listener_name://host_name:port >> # EXAMPLE: >> # listeners = PLAINTEXT://your.host.name:9092 >> #listeners=PLAINTEXT://9092 >> >> # Hostname and port the broker will advertise to producers and consumers. >> If no$ >> # it uses the value for "listeners" if configured. Otherwise, it will use >> the $ >> # returned from java.net.InetAddress.getCanonicalHostName(). >> advertised.listeners=PLAINTEXT://hidden_ip:55091 >> I edited advertised.listeners because there is a proxy to redirect >> requests to the broker. Anyway until some weeks ago everything worked >> fine... >> >> My step to start kafka: >> >> 1- service zookeeper start >> 2- ./kafka_2.11-0.11.0.0/bin/kafka-server-start.sh >> ~/kafka_2.11-0.11.0.0/config/server.properties >> Any advises? Thank you
