1.啟動kafka服務
啟動zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka
bin/kafka-server-start.sh config/server.properties
2.建立乙個主題
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
檢視當前已建立的主題
bin/kafka-topics.sh --list --zookeeper localhost:2181
3.建立乙個生產者，並傳送一些訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
this is a message
this is another message
4.建立乙個消費者，並接受訊息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
this is a message
this is another message
kafka裡的一些管理指令碼
kafka server start指令碼 啟動kafka server kafka server stop指令碼 關閉kafka server kafka topics指令碼 負責kafka中topic相關操作。如 建立topic，查詢topic詳細資訊，新增分割槽並完成新增的副本等等 kafka...
一些常用的shell指令碼命令和用法
代表命令列引數個數 代表所有引數 n 第n個引數 代表最後乙個命令返回值 代表當前shell的程序號pid 是變數的引用符 是最基本的賦值 是覆蓋之前的值 是如果沒有被賦值過就賦予等號後面的值 是新增等號後面的值 declare a array 陣列 declare i sum 10 20 整型 d...
MySQL一些基本命令
1 mysql服務的啟動和停止 net stop mysql net start mysql 2 登陸mysql 語法如下 mysql u使用者名稱 p使用者密碼 鍵入命令mysql uroot p，回車後提示你輸入密碼，輸入12345，然後回車即可進入到mysql中了，mysql的提示符是 mys...