開発者/統合テスト環境向けにApache Kafkaを設定する

Question

私は、開発者&統合テスト環境でApache Kafkaを設定して実行する方法に関するアドバイスと指針を探しています。

開発者のマシンごとにパッケージ全体を手動でダウンロードしてセットアップする必要はなく、統合テストのためにノードを自動的に起動する簡単な方法を見つけることができます。

dev/integrationテスト用に埋め込まれたKafkaがありますか（本格的なRDBMSを避けたいJava開発者にとってはH2並列を考えてください）？

バグ対策の解決策に頼らなければなりませんか？ちなみに、私は次の興味深いGistを見つけました：https://gist.github.com/svanellewee/8d978db827a860186569しかし、それはバガン+ VirtualBoxを設定する必要があります...

Answer 1

DEV /統合テストの目的のために埋め込まれたカフカのいくつかの並べ替え

はありカフカは実際にあなたが埋め込まれたカフカクラスタを実行することができます試験設備を含んでいます。

アップデート2017年3月13日：あなたが経由して、ビルドに関連するMavenの成果物を追加することができます。

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka-streams</artifactId> 
    <!-- Replace with desired Kafka version. --> 
    <version>0.10.2.0</version> 
    <classifier>test</classifier> 
    <scope>test</scope> 
</dependency> 

それは、2017年3月の時点で、カフカプロジェクトがまだ定義されていませんが注意してください上記の試験施設の "契約"。たとえば、将来のバージョンのテスト機能が古いバージョンと下位互換性を持つことは保証されていません。

次のポインタは筆記テストのための参考になります。

• https://github.com/confluentinc/examples - kafka-streamsサブフォルダは、いくつかのケースでは、埋め込まれたカフカクラスターをスピンアップだけでなく、多くのエンド・ツー・エンドの統合テストを含みConfluent schema registry。これらはあなた自身のテストのための良い出発点であるはずです。
• https://github.com/apache/kafka/tree/trunk/streams/src/test/java/org/apache/kafka/streams/integration/utils - 以前のリンクと同様の試験施設が、少ないが、私は手動でダウンロードすることを避けるために希望

例を含まれており、開発者のマシンのそれぞれに全体のパッケージを設定し、また、統合テストのためにノードを自動的に起動する簡単な方法もあります。

これは、maven、gradle、またはsbtなどのツールを使用して既存の開発/テストプロセスとよく似ているため、ニーズが満たされている場合に最も簡単です。

： - など意図的にあなたのアプリケーションには、例えば、部分的な停止を存続することを検証するカフカブローカーの途中でダウン取るように - あなたは、より高度なテストを実行する必要がある場合に

しかし、あなたはを見てみたいことがあります

• https://github.com/apache/kafka/tree/trunk/tests（システムと統合テスト、例えばドッキングウィンドウを使用して）
• https://github.com/apache/kafka/tree/trunk/vagrant
• https://github.com/confluentinc/ducktape

Answer 2

私はKafkaUnitがここでH2に最も近いものだと思います。ここで見つけることができます（https://github.com/chbatey/kafka-unit）。 それともキュレーターTestingserverに似たすべてのJVMにおける単位/統合テストのための

<dependency> <groupId>info.batey.kafka</groupId> <artifactId>kafka-unit</artifactId> <version>0.6</version> </dependency>

作品を経由して使用します。