kafka потребитель не получает сообщение по удаленному

Question

Привет Я новичок в kafka, и у меня есть быстрый вопрос.

Я реализовал продюсер Кафки и потребительский зоопарк и продюсер работает на другом сервере (192.168.10.233) Потребителя работает на другом сервере (192.168.10.234) Оба локально связного

Проблема Потребителя подключиться к сети производителя, но не слушать любое сообщение, но если я перейду эту часть прослушивания на одном сервере (192.168.10.233), он получает сообщения

это мой код для потребителя

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()); 
    } 

    } 

Я также проверил 192.168.10.233:9092 снаружи, погода порт не заблокирован ничем.

Answer 1

Скорее всего, вы должны установить advertised.host.name в свой kafka/config/server.properties значение, которое маршрутизируется снаружи.