Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Welcome To Ask or Share your Answers For Others

Categories

0 votes
151 views
in Technique[技术] by (71.8m points)

How to set Kafka properties (in what property files) in Windows & monitor Kafka cluster health?

I have Kafka setup on my Windows and have a local Kafka cluster of 2 brokers setup. I am trying to debug certain Kafka reliability issues when working with 2 brokers, one going down, both going down, etc., and have a couple of questions.

  1. In what .properties file (just like we have server.properties) can I set the following Kafka related properties: a) broker.rack b) min.insync.replica c) unclean.leader.election.enable d) enable.auto.commit

  2. Where to check for the Kafka consumer 'message' commit logs, when I'm trying to monitor my cluster health?

  3. How do I monitor the 'out-of-sync' behavior of each of my brokers in the cluster? (need this just to see how erratically my brokers are going out of sync in the cluster, and if there is a serious flaw I need to unfold in the cluster configuration)

Answers to my questions, references, ways of debugging cluster health, and inputs are welcome!

question from:https://stackoverflow.com/questions/65850774/how-to-set-kafka-properties-in-what-property-files-in-windows-monitor-kafka

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
Welcome To Ask or Share your Answers For Others

1 Reply

0 votes
by (71.8m points)

You can find all the properties for the server.properties file under Broker Configs. enable.auto.commit is a consumer config.

Not sure I understand what you mean by "commit logs". The consumer group offsets are stored in a topic named __consumer_offsets. All topics are stored in segment files on the broker in log.dirs

You can use tools such as JMX Exporter + Prometheus + Grafana, or Cruise Control for general Kafka monitoring. Both should give you an idea about ISR status


与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
OGeek|极客中国-欢迎来到极客的世界,一个免费开放的程序员编程交流平台!开放,进步,分享!让技术改变生活,让极客改变未来! Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Click Here to Ask a Question

...