2017-12-28 22 views
0

このアプリケーションでは、さまざまなタイプのキューが使用されています。待ち行列を使用するアプリケーションを開始する前に、必要な待ち行列にサンプルメッセージを書き込み、待ち行列が正しく設定されているかどうかを確認するために読み取り(すなわち、削除)する自動事前チェックが行われます。カフカのトピックが正しく設定されているかどうかのテスト

現在、カフカも使用しています。しかし、カフカではトピックを「汚染する」ような実際のアプリケーションを開始する前にメッセージを削除することはできないため、トピックを使ってメッセージを書いたり読んだりすることで事前チェ​​ックを行うことはできません。カフカでこれを行うための他の自動化された方法、API、またはコマンドラインスクリプトがありますか? javaまたはシェルスクリプトでは好ましい。

カフカバージョン0.11.x

答えて

2

kafka-topics --describe --topic YOUR_TOPIC --zookeeper YOUR_ZKは十分であるべきです。同期しているアクティブなレプリカの出力がある場合は、適切に行ってください。別のツールはkafkacatです。ビルトインツーリングが必要なものを提供していない場合(つまり、ZooKeeperにアクセスしたくない/したくない場合)

関連する問題