kafka接受tcpserver并转发

最近刚开始学kafka，公司给的需求是 给我一个ip和端口 比如192.155.48.32:8089 让我连接上并且接收到不断发送的消息。 给的条件就是这个ip和端口 我用centos7 搭建了3个kafka和zookeeper。我现在的进度就在这

，公司给我的ip和端口号我写在了这里

。后面就不知道怎么办了，谢谢

不是已经提供给你broker地址了吗，直接写消费端程序就行了

加入依赖直接编写生产者消费者代码就可以。
可以看看我的博客，最近才总结了一些比较实用的包括生产者和消费者的一些特性。