我在Google Cloud 上部署了Kafka，我改变了听众
PLAINTEXT：// [内部IP地址]：9092
当我尝试
sudo ./bin/kafka-topics.sh --list --zookeeper [外部IP地址]：2181
我可以在经纪人那里得到话题 . 但是，当我尝试向Kafka经纪人发送消息时
sudo ./bin/kafka-console-producer.sh --broker-list [外部IP地址]：9092 - 主题测试
出现以下错误：
ERROR使用key发送消息到主题测试时出错：null，值：5个字节，错误：（org.apache.kafka.clients.producer.internals.ErrorLoggingCallback）org.apache.kafka.common.errors.TimeoutException：Expiring 1 test-0的记录：自批量创建加上延迟时间以来已经过了1506 ms
我想知道我设置了哪些属性以及如何修复它？
1 回答
您需要将
advertised.listeners设置为外部IP，以便客户端可以正确连接到它 . 否则他们将尝试连接到内部IP（因为advertised.listeners将默认为listeners，除非明确设置）参考：https://kafka.apache.org/documentation/#brokerconfigs