當我們用API寫kafka的時候 生產者生產消息,但是消費者接收不到消息?集群上啟動消費者顯示生產的消息。我們需要修改一下配置
(1)我們打開在虛擬機中修改kafka集群的配置文件
[root@spark01 kafka_2.11-0.8.2.2]# vi /usr/local/kafka_2.11-0.8.2.2/config/server.properties
(2)再修改其他兩個虛擬機中的配置,和上面的操作一致
(3)再次運行消費者消息就可以顯示了如下圖所示:
當我們用API寫kafka的時候 生產者生產消息,但是消費者接收不到消息?集群上啟動消費者顯示生產的消息。我們需要修改一下配置
(1)我們打開在虛擬機中修改kafka集群的配置文件
[root@spark01 kafka_2.11-0.8.2.2]# vi /usr/local/kafka_2.11-0.8.2.2/config/server.properties
(2)再修改其他兩個虛擬機中的配置,和上面的操作一致
(3)再次運行消費者消息就可以顯示了如下圖所示:
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。