如何在谷歌云上部署 Kafka答案

【问题标题】：How to deploy Kafka on Google cloud如何在谷歌云上部署 Kafka
【发布时间】：2018-10-05 10:44:12
【问题描述】：

我在谷歌云上部署了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 向主题测试发送消息时出错，键为空，值： 5 个字节有错误： (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) 对于 test-0：自批处理创建以来已经过去了 1506 毫秒加上逗留时间

我想知道我设置错了哪些属性以及如何修复它？

【问题讨论】：

标签： apache-kafka google-cloud-platform cloud

【解决方案1】：

您需要将advertised.listeners 设置为外部IP，以便客户端可以正确连接到它。否则他们将尝试连接到内部 IP（因为 advertised.listeners 将默认为 listeners 除非明确设置）

参考：https://kafka.apache.org/documentation/#brokerconfigs

【讨论】：