一,環境準備
進入原始碼的根路徑,使用gradle編譯 輸入命令:
gradle idea 等待一段時間就可以看到編譯成功
gitbash
export http_proxy= 設定**
./gradlew jar
編譯通過
匯入idea開啟
把client generated/generated-test拷貝到對於client包下,移除src <== todo 不專業
二,kafka伺服器啟動
通過:bin/zookeeper-server-start.sh config/zookeeper.properties啟動zookeeper
kafka服務啟動
主類:kafka.kafka
程式引數: config/server.properties
通過windows的bat命令測試
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic test
檢視zookeeper資訊:bin/zookeeper-shell.sh localhost:2181
kafka-console-producer.bat --broker-list localhost:9092 --topic test
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
消費內部topic __consumer_offsets :
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic __consumer_offsets --formatter "kafka.coordinator.group.groupmetadatamanager$offsetsmessageformatter" --consumer.config consumer_config.properties --from-beginning
consumer.properties 新增exclude.internal.topics=false
kafka-topics.bat --list --zookeeper localhost:2181
消費情況:
kafka-consumer-groups.bat --new-consumer --bootstrap-server localhost:9092 --describe
出錯問題
kafka程式啟動,slf4j: failed to load class "org.slf4j.impl.staticloggerbinder".
除錯RocketMQ原始碼
拷貝namesrv broker的配置檔案到指定目錄,為了避免直接修改 中的配置檔案。1.1 在f盤建立rocketmq資料夾,建立三個子資料夾conf logs store,我的 中多了dev data的資料夾 1.2 將distribution原始碼conf目錄下的broker.conf log...
怎麼除錯Delphi原始碼
delphi除錯概述2007 06 13 16 15delphi除錯入門級的經典文章,如果是新手的話此文值得好好的讀一讀 delphi除錯概述 除非你的程式只有幾行,否則幾乎不可能一次寫成,因此除錯就非常必要。然而許多初學者不知道如何進行除錯,寫完程式就執行,發現結果不對再看 這樣覺得非常吃力。這裡...
Python原始碼 除錯 安裝
寫了一些簡單的python的原始碼,直接執行和除錯即可。但要把code部署安裝起來,還需要一些工作。另外,針對那些需要安裝部署的code,如何進行二次開發,也是乙個很大的問題。如openstack中,我們如何對原始碼二次開發,並部署除錯?本文即關注於這兩個問題。對於第乙個問題,編寫完原始碼,還需要編...