?
?Kafka是由LinkedIn開發的分布式發布 - 訂閱消息系統,具備高吞吐量、低延遲、可擴展性、持久性、可靠性、容錯性和高并發等特性。其主要角色包括Broker、Topic、Partition、Producer、Consumer、Consumer Group、replica、leader、follower和controller。消息系統中存在點對點和發布訂閱兩種模式,Kafka在大數據流式處理場景優勢明顯。安裝Kafka前需安裝JDK和Zookeeper,安裝時要注意版本選擇,安裝完成后需對配置文件進行修改和分發。啟動Kafka集群前要先啟動Zookeeper,還可配置環境變量實現一鍵啟動和關閉
在命令行使用方面,Kafka提供了豐富的命令用于管理和操作。可創建、查看、刪除topic,進行數據生產與消費。生產數據時指定broker和topic,消費數據時可從指定位置開始,還能指定groupid。