我的问题是:如何将数据从kafka 生产环境 者发送到经纪人?下面的架构解释了我的网络配置:
我在VM中有一个 生产环境 者,它位于服务器A中,我的代理也位于服务器B中的VM中 .
我使用从 生产环境 者VM到服务器B的 SSH
连接以及重定向端口:ssh -L 9092:192.168.56.101:9092 xx @ IP1
我使用kafka控制台来测试:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
谢谢
1 回答
您需要将--broker-list设置为代理所在的位置 . 在您的代码中,您说我想生成一条消息并将其发送到位于端口9092的localhost机器上的代理 . 尝试bin / kafka-console-producer.sh --broker-list 192.168.56.101:9092 - 主题测试