kakfa原始碼除錯

2021-10-06 13:30:30 字數 1406 閱讀 6176

一,環境準備

進入原始碼的根路徑,使用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中,我們如何對原始碼二次開發,並部署除錯?本文即關注於這兩個問題。對於第乙個問題,編寫完原始碼,還需要編...