Kafka 上で実行され、samza を使用するイベント ソーシング (またはステートフル ストリーム処理) アプリケーションをテストおよびデバッグしています。起動時に samza ジョブが空のカフカをインストールできるように、カフカのキューとトピックを削除したいと考えています。
どうすればできますか??
編集：
質問は、私が最初に書いたものよりもかなり複雑で具体的です。
Davidが述べているように、kafka 0.8.2から始まるトピックをパージする解決策があります： Purge Kafka Queue
私が興味を持っているのは、zookeeper と kafka (私の git リポジトリーにバイナリー・パッケージとしてバンドルされています) を自動的にロードするテスト環境をセットアップすることです。
私はgradle環境+ eclipseとJUnitを使用しています。Eclipse から統合テストを実行します (JUnit テストとして)。
ロードはどのように自動化できますか? 環境をセットアップし、kafka と Zookeeper を起動するには、特定の Test クラスを作成する必要がありますか? 参考例/コードはありますか？アイデアは、環境をロードし、いくつかのテストを実行して停止することです。このプロセスが数秒で完了できれば、さらに良いでしょう。