問題タブ [reactive-kafka]

Scalaでreactive-kafkaモジュールを使用するコードに取り組んでいます。私のコードは次のような行を使用します。

2 つの質問があります。

1. 私のコードがパッケージ com.softwaremill.react.kafka をインポートしていることがわかります。詳細なドキュメントへのリンクを教えてもらえますか? これまでに見つけたすべての情報は、あまりにも良心的です。

2. サーバーがまだ Kafka に接続されていることを確認したい。com.softwaremill.react.kafka パッケージを使用してどうすればよいですか?

react-kafka モジュールのコードを使用する必要があります: https://github.com/akka/reactive-kafka/blob/master/README.md

私のコードは次のように始まります:

（出版社による）メッセージを出したい。それを実現するために書かなければならないコードは何ですか？

私は次のドキュメントを見ました: https://github.com/akka/reactive-kafkaそして、次のコードスニペットを見ました:

「publisher」が Kafka にメッセージを書き込むことになっていることを理解しています。ただし、Kafka の Consumer は正反対の意味であり、コンシューマーが Kafka からメッセージを読み取ることを意味します。もしそうなら、「publisher」が kafka.consume(ConsumerProperties...) に関連していることはどのように理にかなっていますか?

サービスに送信したい Kafka Reactive Streams コンシューマからバイト文字列としてファイルを受信して​​います。

Kafka Reactive Stream Consumer から Source[Bytestring, Any] を抽出して、Bytestring 全体をメモリにロードしてから akka-http リクエストを実行することなく、Kafka から Akka-http にストリームをチェーンできるようにする方法はありますか?

Kafka を使用して大きなファイルを送信する場合、複数のパーティションに分散してから Akka-Stream を使用して再構築することは可能ですか? このプレゼンテーションで説明されているように:

http://www.slideshare.net/JiangjieQin/handle-large-messages-in-apache-kafka-58692297

カフカからメッセージを取得し、それらをいくつかのデータにラップして外部サービスに送信する単純なサービスを実装しようとしています。

メッセージを処理するときに外部サービスが利用できない場合の一般的なパターンは何ですか?

これまでのところ、外部サービスへのリクエストが成功した場合にのみ、メッセージを手動でコミットしています。外部サービスの失敗の処理が消費者に透過的になるように、コミットされていない場合、しばらくしてからカフカにメッセージを再送信してもらいたいと思います。私はそれを行う方法を見つけることができませんでした。ただし、アンチパターンを行っていない場合は興味があり、より良い解決策があります。