kafka測試同一個消費組的多個消費者負載均衡實例(集成spring)

這裏使用的是zookeeper和kafka3臺機器的集羣,這樣能保證如過有一臺機器炸了還能運行,在集羣環境中,要在kafka的 server.properties中配置zookeeper集羣地址等信息,最重要的是num.partitions=3.這樣一個分區就是一個機器,所以當kafka發消息的時候就會發送到每個機器上。 就是因爲這個才踩到一個坑,集羣配置好了,創建topic設置了3個分區,2個備
相關文章
相關標籤/搜索