我已经在ec2上安装了kafka软件。我的问题是从aws外部连接到代理。这一切都对我有好处。
所以我可以启动代理，kafka控制台生产者和消费者都可以工作（从同一台服务器）。我有端口2181和9092开放到远程位置，从那里我想使用生产者。所以从我的开发（本地）机器。。如果我使用telnet 9092-它会连接我。如果我尝试使用Kafka控制台生产者我得到这个错误。 [2017-03-09 15:04:44,971] ERROR Error when sending message to topic topic2 with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic2-0: 1521 ms has passed since batch creation plus linger time 我尝试了各种与server.properties文件和上的组合-使用密钥 listeners 以及 advertised.listeners .
我真的很感谢你的帮助。。。
1条答案
按热度按时间g0czyy6m1#
这可能是因为aws机器的公共主机名/ip不能在aws内部使用。如果是这样的话，你需要做一点软糖。需要两件事：
一定要准备好
advertised.listeners你的私人地址在local/etc/hosts中，将aws的本地主机名（例如ip-10-0-0-1.eu-west-1.compute.internal）绑定到公共ip
然后确保始终只使用私有主机名。这一直是我的根本原因，许多奇怪的问题，不给任何日志。