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命令提示符的引數標誌了,為了不混淆,所以採用 反斜槓 ...