Kafka remote consumer无法获取消息

Question

我设置了3个节点汇流/Kafka都指向同一个动物园管理员

所有3台服务器都已播发。Listener=带有明文的公共ipv4

broker.id.generation.enable=true
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://PUBLIC-IPv4:9092
listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
zookeeper.connect=10.114.16.19:2181

bootstrap.servers=10.114.16.19:9092,10.114.16.21:9092,10.114.16.20:9092

producer = KafkaProducer(
    bootstrap_servers='PUBLIC-IP:9092',
    value_serializer=lambda v: json.dumps(v).encode('utf-8'))

producer.send('slim', {'topic': 'kafka'})

print('Making connection.')
consumer = KafkaConsumer(bootstrap_servers='PUBLIC-IP:9092')

print('Assigning Topic.')
consumer.assign([TopicPartition('slim', 2)])

print('Getting message.')
for message in consumer:
    print("OFFSET: " + str(message[0])+ "\t MSG: " + str(message))

当我运行消费者py客户机时，它只是保持打开状态，没有得到任何消息来澄清上面我在网上找到的测试代码，我没有编写它，因为我还在学习Kafka API

Answer 1

首先，请确保您能够pingpublic-ippublic-ip，并且您没有陷入DNS问题。如果您在Linux平台上，则安装kafkacat，并通过以下命令测试它是否可以使用数据：

kafkacat -b <BROKER_IP> -t <TOPIC_NAME>