問題タブ [reactive-kafka]

Kafka サーバーをセットアップし、プロデューサーを使用してメッセージを送信することで、コードをローカルでテストしようとしましたが、このコードの単体テストを作成する方法があるかどうか疑問に思っています (メッセージが受信されたかどうかをテストします)。消費者が正しい）。

私はSpring 5、詳細にはReactorプロジェクトを使用して、膨大なMongoコレクションからKafkaトピックへの情報を読み取ります。残念ながら、Kafka メッセージの生成は、それらを消費するプログラムよりもはるかに高速です。したがって、背圧メカニズムを実装する必要があります。

毎秒 100 メッセージのスループットが必要だとします。少しグーグルで調べた結果、buffer(int maxSize)メソッドの機能を組み合わせて、定義済みの間隔を使用してメッセージを送信する で結果を圧縮することにしました。Flux

これを行うよりスマートな方法はありますか？つまり、少し複雑に思えます (zip 部分、全体)。

リアクティブ ストリームとノンブロッキング IO 操作に Project Reactor Kafka を使用している 1 つの Java ベースのサービスに Zipkin トレースを実装する必要があります。リアクティブ Kafka をサポートする勇敢な計測ライブラリが見つかりませんでした。

標準の Kafka クライアント brave インストルメンテーション:

https://github.com/openzipkin/brave/tree/master/instrumentation/kafka-clients

Reactive-Kafka をサポートしていません。

Java でのリアクティブ Kafka の Zipkin トレースに役立つライブラリまたはリポジトリはありますか?