問題タブ [reactive-kafka]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
akka-stream - プロデューサー フローをグラフに接続する
私は akka ストリーム kafka (および一般的な akka ストリーム) を使用するのは初めてです。メッセージをさまざまなトピックに公開するために、グラフを作成しようとしています。処理されたメッセージをコミットするためにプロデューサーをフローとして接続するにはどうすればよいですか? Producer.flow を使用してみましたが、取得できませんcommitScaladsl
scala - akkaストリームkafka(reactive-kafka)をakka httpアプリケーションに統合するには?
私は基本的な scala akka http CRUD アプリケーションを持っています。関連するクラスについては、以下を参照してください。
たとえば、エンティティが作成/更新されるたびに、エンティティ ID と一部のデータ (json として) を Kafka トピックに書き込みたいだけです。
http://doc.akka.io/docs/akka-stream-kafka/current/producer.htmlを見ていますが、scala と akka は初めてで、アプリケーションに統合する方法がわかりませんか?
たとえば、上記のドキュメントから、これはプロデューサーが kafka に書き込む例であるため、同様のことが必要だと思いますが、アプリケーションのどこにこれを配置する必要がありますか? ユーザーを作成した後で、サービスの create メソッドに別のマップ呼び出しを追加することはできますか?
どうもありがとう！
または、Server.scala の bindAndHandle() メソッドでhttps://github.com/hseeberger/accessusの例のようなことをする必要がありますか?
WebServer.scala
Router.scala
Service.scala
Repo.scala
scala - java.util.concurrent.Future が見つかりました 必須 scala.concurrent.Future
関連: java.util.concurrent.Future の scala.concurrent.Future ラッパー
これは私の他の質問から来ました：
akkaストリームkafka(reactive-kafka)をakka httpアプリケーションに統合するには?
AKKA HTTP アプリケーションがあり、次のように、ルートの onComplete 関数でメッセージ/ProducerRecord を Kafka に送信したいと考えています。
ただし、onComplete(producer send producerRecord)は次のタイプの不一致エラーを生成しています:
[エラー] が見つかりました: Future[org.apache.kafka.clients.producer.RecordMetadata] (java.util.concurrent 内) [エラー] 必須: Future[org.apache.kafka.clients.producer.RecordMetadata] (scala.同時) [エラー] onCompleteRecordMetadata { _ =>
これを回避する方法はありますか?おそらくプロデューサーをシンクとして使用することで ( http://doc.akka.io/docs/akka-stream-kafka/current/producer.html#producer-as-a-sink ) Javaのプロデューサー.送信機能?