kafka消息的處理機制(五)

這一篇我們不在是探討kafka的使用,前面幾篇基本講解了工作中的使用方式,基本api的使用還需要更深入的去鑽研,多使用纔會有提高。今天主要是探討一下kafka的消息複製以及消息處理機制。 1. broker的註冊 Kafka使用Zookeeper來維護集羣成員的信息。每個broker都有一個唯一標識符,這個標識符可以在配置文件裏指定,也可以自動生成。在kafka啓動的時候,他通過創建臨節點把自己的
相關文章
相關標籤/搜索