Testen, ob Kafka korrekt eingerichtet ist

Question

Unsere Anwendungen verwenden verschiedene Arten von Warteschlangen. Jedes Mal, bevor die Anwendung gestartet wird, die Warteschlangen verwendet, findet eine automatische Vorprüfung statt, die Beispielnachrichten in erforderliche Warteschlangen schreibt und diese liest (d. H. Löscht), um zu bestätigen, ob die Warteschlange ordnungsgemäß eingerichtet ist.

Jetzt verwenden wir auch Kafka. Aber in Kafka können wir keine Vorabprüfung durchführen, indem wir Nachrichten mit Topics schreiben und lesen, weil die Nachrichten nicht gelöscht werden können, bevor die eigentliche Anwendung gestartet wird, was das Thema "verschmutzt". Gibt es in Kafka andere automatisierte Wege, APIs oder Kommandozeilenskripte? Bevorzugt in Java oder Shell-Skripten.

Kafka Version 0.11.x

Answer 1

A kafka-topics --describe --topic YOUR_TOPIC --zookeeper YOUR_ZK sollte ausreichend sein. Wenn eine Ausgabe mit aktiven Replikaten erfolgt, die synchron sind, sollte es gut gehen. Ein alternatives Tool ist kafkacat, wenn das integrierte Tool nicht das bietet, was Sie benötigen (d. H. Sie können nicht auf ZooKeeper zugreifen).