建立測試 topic:
bin/kafka-topics.sh -zookeeper localhost:2181 --create --partitions 5 --replication-factor 1 --topic test765
生產測試訊息:
為 topic test765 生產 500000 條訊息：
bin/kafka-producer-perf-test.sh --topic test765 --throughput -1 --record-size 10 --num-records 500000 --producer-props bootstrap.servers=localhost:9092
獲取 topic 訊息數:
bin/kafka-run-class.sh kafka.tools.getoffsetshell --broker-list localhost:9092 --topic test765 --time -1
test765:0:100000
test765:1:100000
test765:2:100000
test765:3:100000
test765:4:100000
bin/kafka-run-class.sh kafka.tools.getoffsetshell --broker-list localhost:9092 --topic test765 --time -2
test765:0:0
test765:1:0
test765:2:0
test765:3:0
test765:4:0
–time-1 表示要獲取指定topic所有分割槽當前的最大位移，–time-2 表示獲取當前最早位移。
兩個命令的輸出結果相減便可得到所有分割槽當前的訊息總數。
分割槽當前的訊息總數 = [–time-1] - [–time-2]
相減是因為隨著 kafka 的執行，topic 中有的訊息可能會被刪除，，因此 --time-1 的結果其實表示的是歷史上該topic生產的最大訊息數，如果使用者要統計當前的訊息總數就必須減去 --time-2 的結果。
本例中沒有任何訊息被刪除，故 --time-2 的結果全是0，表示最早位移都是0，訊息總數等於歷史上傳送的訊息總數。
由當前工作牽引出的topic
通過google發現 1 重點部分實質是牽涉到了 2 windows remote desktop protocol，該技術十分先進，基於t.120。4 windows presentation foundation wpf 全新的顯示架構。win在向linux的桌面系統取經ing 以上link 專...
由當前工作牽引出的topic
通過google發現 1 重點部分實質是牽涉到了 2 windows remote desktop protocol，該技術十分先進，基於t.120。4 windows presentation foundation wpf 全新的顯示架構。win在向linux的桌面系統取經ing 以上link 專...
獲取當前時間
獲取日期 時間 datetime.now.tostring 2008 9 4 20 02 10 datetime.now.tolocaltime tostring 2008 9 4 20 12 12 獲取日期 datetime.now.tolongdatestring tostring 2008年9...