問題タブ [smallrye-reactive-messaging]

JBoss EAP 7.3 にデプロイする必要がある Smallrye Mutiny を使用する microprofile アプリケーションがあります。マイクロプロファイル機能を有効にするために JBoss EAP XP パッチを適用しました。Mutiny jar も EAP のモジュールとして追加しました。以下はモジュールファイルの内容です

そして、reactivestreams の module.xml は

ただし、私のアプリケーションでは、サービスモジュールローダーからモジュール「deployment.SampleReactive.war」でクラス io.smallrye.mutiny.Multi を定義できませんでした: java.lang.NoClassDefFoundError: Failed to link io/smallrye/mutiny という例外が発生します。 /Multi (サービス モジュール ローダーのモジュール「deployment.SampleReactive.war」): org/reactivestreams/Publisher

Microprofile を使用してビルドされたリアクティブアプリケーションで動作するように JBoss EAP を設定するにはどうすればよいですか? どんな助けでも大歓迎です。

編集: アプリを EAP 7.3 で動作させることができました。しかし今、私は別の問題に直面しています。アプリには、Uni と Multi を出力する REST API があります。REST API は Json を生成します。しかし、このプログラムを EAP で実行すると、JSON ではなく、オブジェクトが応答として表示されます。EAP は Uni と Multi を JSON に変換できないようです。

これを機能させるために追加する必要があるライブラリはありますか?

一括処理したい。私の使用例では、kafka プロデューサー メッセージを 1 つずつ送信します。それらをコンシューマーアプリケーションのリストとして読みたいです。Spring Kafka ライブラリでそれを行うことができます。Spring Kafka バッチ リスナー

quarkus-smallrye-reactive-messaging-kafka ライブラリでこれを行う方法はありますか?

以下の例を試しましたが、エラーが発生しました。

アプリケーションのプロパティ:

TestConsumerDeserializer:

マイコンシューマー:

私のシナリオでは、アプリケーションは CDI-Producer を使用して JMS キューからメッセージを読み取ります。

私は quarkus-smallrye 実装を使用しています。

コネクタは非常に単純に見えます。

構成:

メッセージを処理するさまざまな方法を試しましたが、いずれの場合もワーカー スレッドは 1 つしかありませんでした。

ログには毎回同じ結果が表示されます。

私はこのドキュメントを使用して、たくさん検索しました;-)

私の間違いは何ですか？スレッドが 1 つしか実行されないのはなぜですか? さらに情報が必要な場合は、お知らせください。

次のガイドhttps://smallrye.io/smallrye-reactive-messaging/smallrye-reactive-messaging/2/testing/testing.htmlに従って、kafka ブローカーなしでテストしています。次の QuarkusTestResource をセットアップしました。

そしてこのように使用されました

ただし、常に次のエラーが発生します。

私は本当に私が欠けているものを手に入れません。私はそれがばかげていると確信しています。