kafka consumer keine Nachricht über remote

Question

Hallo ich bin neu zu kafka und ich habe eine kurze Frage.

ich implementiert einen kafka Erzeuger- und Verbraucher zookeeper und Produzenten in einem anderen Server ausgeführt wird (192.168.10.233) Consumer in einem anderen Server läuft (192.168.10.234) Beide sind mit lokal

Problem ist Verbraucher Setzen sie sich mit Produzenten verbunden, aber keine Nachricht hören, aber wenn ich dieses Zuhören Teil auf denselben Server (192.168.10.233) bewegen, er empfängt die Nachrichten

dies ist mein Code für Verbraucher

def listen(): Unit = { 
    val props = new Properties(); 
    props.put("bootstrap.servers", "192.168.10.233:9092"); 
    props.put("group.id", "groupId"); 
    props.put("enable.auto.commit", "true"); 
    props.put("auto.commit.interval.ms", "1000"); 
    props.put("session.timeout.ms", "30000"); 
    props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); 
    props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); 
    val consumer = new KafkaConsumer(props); 

    println("calling ---- but yet to receive the message") 

    consumer.subscribe(List("test")); 
    while (true) { 
     val records = consumer.poll(100); 
     for (record <- records) 
     println("offset = %d, key = %s, value = %s", record.offset(), record.key(), record.value()); 
    } 

    } 

Ich überprüfte auch 192.168.10.233:9092 von außen, Wetter der Hafen ist durch nichts blockiert.

Answer 1

Höchstwahrscheinlich müssen Sie advertised.host.name in Ihrem kafka/config/server.properties auf einen Wert einstellen, der von außen routingfähig ist.