本記事では、QuarkusアプリケーションをKafkaインスタンスと組み合わせて使用する方法について説明しています。
まず、Red Hat Hybrid Cloud ConsoleでKafkaインスタンスとService Registryインスタンスを作成し、アクセス権を設定します。
次に、ローカル開発環境を用意し、ソースコードをGitHubからインポートします。
その後、KafkaとService Registryにアクセスするための設定を行い、Kafkaトピックを作成します。

サンプルアプリケーションでは、ConsumerアプリケーションがKafkaトピックからメッセージを取得し、ブラウザに表示する一方で、Producerアプリケーションが5秒ごとにランダムな値を生成し、Kafkaトピックにパブリッシュします。
このサンプルアプリケーションでは、AvroフォーマットのスキーマのシリアライズとデシリアライズにService Registryの機能が利用されています。
これにより、スキーマの進化に対応し、サービスレジストリにスキーマを登録してルールを設定することができます。