kafka基礎以及相關cmd操作

2021-10-12 08:39:28 字數 2280 閱讀 5065

kafka:基於發布訂閱模式(一對多)

訊息佇列:解耦,提高通訊效率

同步非同步

啟動kafka時出現

修改第179行,將裡面的%classpath%修改為"%classpath"即可

cmd code,下面有擷取相關的介面

# start zookeeper service (port: 2181)

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

# start kafka broker serivce (port: 9092)

bin\windows\kafka-server-start.bat config\server.properties

# create a new kafka topic "test"

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

# list out all kafka topic

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

# describe specific kafka topic "test"

bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

# publish data to specific kafka topic "test"

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

>hello

>hello2

# publish data with key & value to specific kafka topic "test"

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 ^

--topic test ^

--property "parse.key=true" ^

--property "key.separator=:"

>8703147:hello3

>8703147:hello4

# subscribe specific kafka topic "test"

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

# subscribe specific kafka topic "test" with key & value displayed

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning --property print.key=true --property key.separator=":"

大致的操作介面

kafkaapi使用參考:

Oracle RAC相關以及基礎知識

rac相關以及基礎知識 一 rac相關以及基礎知識 1.crs簡介從oracle 10g開始,oracle引進一套完整的集群管理解決方案 cluster ready services,它包括集群連通性.訊息和鎖.負載管理等框架.從而使得rac可以脫離第三方集群件,當然,crs與第三方集群件可以共同使...

使用cmd命令查詢檔案位置以及檢視相關程序

方法1 使用find過濾dir s b find py3 flask 缺點 會把所有包含 py3 flask 的路徑都找出來 方法2 使用萬用字元c dir s b py3 flask 找出以py3 flask結尾的路徑,這種方法適應性更廣 dir s b 列出當前目錄及子目錄下的所有檔案 1 檢視...

計算機基礎1 cmd進入其他碟符以及檔案路徑

絕對路徑是指目錄下的絕對位置,直接到達目標位置,通常是從碟符開始的路徑。windows system32無論當前路徑是什麼,會自動地從當前盤的根目錄開始查詢指定的程式 相對路徑就是相對於當前檔案的路徑 2 windows由於使用 斜桿 作為dos命令提示符的引數標誌了,為了不混淆,所以採用 反斜槓 ...