生產命令
消費命令
topic刪除命令
topic描述命令
在linux執行kafka bin/kafka-server-start ../config/server.properties
1.建立乙個topic
kafka_home/bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
2. 檢視topic列表
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
3.向topic傳送資料
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
test message 1
test message 2
3.從topic讀取資料
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
4.檢視kafka消費組的列表（0.9版本以上）
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list
5.修改讀取offset到當前的位置
/bin/kafka-run-class.sh kafka.tools.updateoffsetsinzk latest test.properties test
6.檢視消費情況
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --describe --group test
7.刪除主題操作
bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic test
8.檢視topic描述
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic test
基本客戶端操作
gopher client chapter 1 gopherclient.py import socket,sys port 70 host sys.argv 1 filename sys.argv 2 s socket.socket socket.af inet,socket.sock strea...
hdfs客戶端操作
hdfs的客戶端有多種形式 網頁形式 命令列形式 客戶端在 執行，沒有約束，只要執行客戶端的機器能夠跟hdfs集群聯網 檔案的切塊大小和儲存的副本數量，都是由客戶端決定！所謂的由客戶端決定，是通過配置引數來定的 hdfs的客戶端會讀以下兩個引數，來決定切塊大小 副本數量 切塊大小的引數 dfs.bl...
hdfs客戶端操作
這裡hdfs客戶端指的是eclipse 一 獲取hadoop安裝包解壓後進入share資料夾裡面的所有jar包 二 這裡如果你客戶端 eclipse所在機器 是win7，需要編譯hadoop原始碼來適應你的機器。三 配置hadoop home環境變數和path 四 拷貝win7電腦上的檔案到虛擬機器...