本文內(nèi)容主要引用自:https://www.cnblogs.com/fonxian/p/12105142.html
通過idea來調(diào)試Kafka源碼堪置,首先參考:http://www.reibang.com/p/8800ec1c4b90
在idea中運(yùn)行Kafka主要配置有兩個
- 可用的zookeeper
- 指定server.properties
在idea中運(yùn)行kafka只需要在core/src/main/scala/kafka/Kafka.scala上右鍵運(yùn)行即可。首先記得本地先運(yùn)行一下zookeeper张惹,然后在idea的運(yùn)行配置中指定運(yùn)行參數(shù)config/server.properties舀锨。
根據(jù)第一個文檔還可以添加一些jvm的參數(shù),如:
-Dcom.sun.management.jmxremote.port=9999
-Dcom.sun.management.jmxremote.ssl=false
-Dcom.sun.management.jmxremote.authenticate=false