問題タブ [smallrye-reactive-messaging]

Confluent SchemaRegistry が Quarkus および MicroProfile で機能しない

以下のエラーで終わる

avro を使用して kafka メッセージを逆シリアル化するためにスキーマ レジストリ (Confluent`s) を以下のように構成しようとすると、kafka トピックで利用可能な avro シリアライザー メッセージを逆シリアル化する必要がある Quarkus kafka コンシューマー アプリケーションを構築しようとしました。例外

構成

以下のように試してみました

プロパティ

以下のように試してみました

quarkus で smallrye-kafka を使用して SSL で kafka トピックに接続したくありません。

私のコードは実行時に機能しmvn compile quarkus:devます。

mvn clean package -Pnative成功しています。しかし、ネイティブ バイナリを実行すると、見つからないため失敗しますSaslClientCallbackHandler。SSL を使用してネイティブをビルドし、smallrye 拡張機能を使用して kafka を構成するための quarkus ガイドに従いました。

私のapplication.propertyファイル

ネイティブも同じように機能することを期待しています。がコメントされている場合application.property、ネイティブ実行は例外をスローしません。

エラーログ：

再現するには：

1. quarkus-smallrye-reactive-messaging-kafka拡張機能を使用して新しい quarkus プロジェクトを作成する

2. アプリケーション プロパティの構成

3. ネイティブをビルドして実行します。

注: にクラスがありませんsrc/main/java。SSL 構成が で見つかった場合、ネイティブは失敗します。application.property

私の Camel ルート アプリは、他のアプリの公開された ampq メッセージ (公開番号) を検出しますが、「利用可能な型コンバーターがありません」というエラーで処理に失敗します。どうすれば解決できますか？

ルートビルダークラス

pom.xml

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

コンソールスタックトレース (抜粋)

その他の注意事項

パブリッシング アプリは、Quark Ampq の例に基づいています:
https://github.com/quarkusio/quarkus-quickstarts/tree/master/amqp-quickstart/src/main/java/org/acme/quarkus/sample

テクノロジー

ジャワ8

クォークス

スモールライ

キャメル

メイヴン

親愛なる、私はある種のイベント駆動型マイクロサービスをやろうとしています。現在、Quarkus & Smallrye-Reactive メッセージング拡張機能を使用して、メッセージを受信したときに Kafka からメッセージを消費し、データベース レコードを更新することができました。さらに達成したいのは、成功した場合は他のトピックにメッセージを送信し、そうでない場合はエラートピックにメッセージを送信できるようにすることです。return および @outgoing アノテーションを使用して新しいメッセージを送信できることはわかっていますが、私の使用例には合わないと思います。メッセージの消費中にエラーが発生した場合は、ここでガイダンスが必要です。メッセージを元のトピックに返す必要がありますか (メッセージを確認せずに)、それを消費して別のトピックにエラー メッセージを生成し、元のトランザクションをロールバックする必要があります。

これが私のコードです:

また、より良いコードがあれば送信してください。私はまだリアクティブプログラミングの初心者です:)。