我正在使用斯卡拉Spark流處理Kafka。我需要從多個主題獲取郵件。爲此,我需要輸入每個主題的消費者組。Apache Kafka:如何找出一個話題的消費羣?
我曾嘗試下面的命令:
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name
對於這一點,我需要一提的消費羣,並檢查自己的主題,這是否組下下降。但我不知道某些主題的消費羣體價值。
那麼,是否有任何命令或編程方式查找給定主題的消費羣?
任何幫助,將不勝感激。 謝謝
任何人,請建議一個命令或API來獲得消費者羣體。 – Arjun