kafka的常見操作。
先確保計算機上已經裝了jdk。
修改計算機的名稱。先輸入hostname進行檢視
為什麼要檢視這個主機名呢？
答: 這是當有遠端計算機需要連線本機的kafka時，需要在遠端計算機hosts中配置:
解壓安裝包：
tar xvf kafka_2.12-1.0.0.tgz
1、修改kafka中的zookeeper的配置。
2、修改kafka的配置，config/server.properties
3、啟動zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &
4、啟動kafka
bin/kafka-server-start.sh config/server.properties &
5、建立乙個topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic returnflow 6
、檢視topic
bin/kafka-topics.sh --list --zookeeper localhost:2181 7
、建立生產者， send some messages
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic returnflow 8
、 啟動乙個客戶端(消費者)
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic returnflow --from-beginning
停止kafka
bin/kafka-server-stop.sh
kafka安裝配置詳解
1.啟動zookeeper，jps quorumpeermain即啟動成功，詳見 2.download kafka from 3.將壓縮檔案上傳至server目錄，解壓 4.進入kafka目錄，執行.bin kafka server start.sh config server.properties...
kafka詳解一 Kafka簡介
分類 kafka 2014 08 18 10 45 375人閱讀收藏 舉報 背景 當今社會各種應用系統諸如商業 社交 搜尋 瀏覽等像資訊工廠一樣不斷的生產出各種資訊，在大資料時代，我們面臨如下幾個挑戰 如何收集這些巨大的資訊 如何分析它 如何及時做到如上兩點 以上幾個挑戰形成了乙個業務需求模型，即生...
Kafka 水位詳解
kafka中用水位來描述，乙個分割槽中的可見資料的offset。大概你需要知道這幾點 hw 水位 你可以理解成是乙個全域性 所有副本最小offset 的offset，針對的是乙個分割槽 leo代表著該副本的所有訊息的最大offset，針對的是乙個副本，也就是每個副本都有leo，並且不一樣。其中所有副...