カフカシンクとしてのRESTエンドポイント

Question

カフカの世界は初めてです。データストリーミングのニーズを満たすためにカフカを設立する予定です。私たちの場合のシンクは、RESTエンドポイントです。 Kafka => RESTエンドポイント接続をサポートするために使用できるコネクタは何ですか？これは、AWSの単純なキューやトピックの仕組みと似ています。

Answer 1

AFAIK Apache Kafkaの認定HTTPシンクはありません。単にカフカコンシューマを作成して、すべてのメッセージ（またはメッセージバッチ）に対してサービスへのREST呼び出しを行うのはなぜですか？

Answer 2

私は気付いていることはありませんが、akka-streamsはこのユースケースに適していると感じています。

ソースはカフカメッセージストリームはアッカ・ストリームカフカ（別名反応性カフカ）とシンクアッカ-HTTPクライアント（フローベースの変異体）を使用して作成されるであろう：アッカため http://doc.akka.io/docs/akka-http/10.0.6/scala/http/client-side/request-level.html#flow-based-variant

統合パターンをAlpakkaという名前で文書化されています（0120）。http://developer.lightbend.com/docs/alpakka/current/