Ich verwende kafka-python und ich frage mich, ob es eine Möglichkeit gibt, alle Themen anzuzeigen.Kafka-python rufen Sie die Liste der Themen
Etwas wie folgt aus:
./bin/kafka-topics.sh --list --zookeeper localhost:2181
import kafka
consumer = kafka.KafkaConsumer(group_id='test', bootstrap_servers=['server'])
consumer.topics()
Danke, es funktioniert wie ein Charme – sathiyarajan
Klingt gut, funktioniert nicht "ValueError: Topic Name" * "ist illegal, es enthält ein anderes Zeichen als ASCII alphanumerics,". "," _ "Und" - "" –
Versuchen Sie es mit der Methode KafkaConsumer.topics().
Dies scheint Kafka nicht nach den verfügbaren Themen zu durchsuchen, sondern listet nur die Themen auf, die eine Verbraucherinstanz abonniert hat. –
Dies ist keine statische Methode, so muss eine Instanz von KafkaConsumer erstellen, um es zu verwenden, aber es stellt sich heraus, dass Sie das ohne eine Themenliste tun können, und es wird in der Tat die Themen von kafka auflisten –
haben sie versucht, mit http://kafka-python.readthedocs.org/en/1.0.2/apidoc/KafkaConsumer.html#kafka.KafkaConsumer.topics? – Markon
Vielen Dank, ist was ich gesucht habe. Wenn Sie eine Antwort schreiben möchten, werde ich sie als korrekt markieren. Vielleicht könnte es auch für andere nützlich sein. – teoreda