当我尝试使用 Kafka 控制台消费者/生产者通过互联网访问 Kafka 实例时,出现超时错误。
对服务器的 Ping 时间约为 190 毫秒。端口可访问。我已通过 telnet 连接到该服务器,没有任何问题。
我运行以下命令:
kafka-console-producer.sh --broker-list example.com:9092 --topic mytopic
出现提示符>
,我输入一些消息。60 秒后,出现以下错误:
错误 向主题 mytopic 发送消息时出错,其中键:null,值:5 个字节,错误:(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)org.apache.kafka.common.errors.TimeoutException:60000 毫秒后无法更新元数据。
当我通过 SSH 进入服务器并从服务器内部(甚至是另一个 ping 时间较短的服务器)运行控制台生产器时,相同的命令可以很好地工作。
我在开发过程中需要从笔记本电脑连接到 Kafka 实例。我该如何解决这个问题?