I know how to Kafka broker configuration properties in Ambari. But, Not sure, How to check Consumer properties in Amabari.
I would appreciate your reply on this.
Thanks in advance.
Yes it does not. Default consumer.properties created by Ambari does not has any cluster specific information. Here is what I found in my setup.
zookeeper.connect=127.0.0.1:2181 # timeout in ms for connecting to zookeeper zookeeper.connection.timeout.ms=6000 #consumer group id group.id=test-consumer-group #consumer timeout #consumer.timeout.ms=5000
If you wish to run kafka console consumer and are looking for arguments for a command such as:
/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server node1.example.com:6667 --topic topic --new-consumer --security-protocol PLAINTEXTSASL --from-beginning --timeout-ms 2000
You will be able to find this using ambari.