Kafkaの使用 パーマリンク to " Kafkaの使用"
機能 パーマリンク to "機能"
Kafkaは人気のあるパブリッシュ/サブスクライブ型メッセージングシステムです。JHipsterはKafkaをオプションでサポートしており、次のことを実現します。
- KafkaクライアントをJHipsterで構成します。
application-*.yml
に必要な設定を追加します。- Docker Compose設定ファイルを生成します。これによりKafkaが
docker-compose -f src/main/docker/kafka.yml up -d
で使用可能となります。
前提条件 パーマリンク to "前提条件"
新しいアプリケーションを生成し、使用したいテクノロジのプロンプトが表示されたら、必ずAsynchronous messages using Apache Kafka
を選択してください。Docker Compose設定ファイルが生成され、次のコマンドでKafkaを起動できます。
docker-compose -f src/main/docker/kafka.yml up -d
コンシューマとプロデューサ パーマリンク to "コンシューマとプロデューサ"
コンシューマ(<appName>KafkaConsumer
クラス)が実行されており、ニーズに適合させることができます。
プロデューサ(<appName>KafkaProducer
クラス)も使用でき、RESTエンドポイント(<appName>KafkaResource
クラス)を介して呼び出すことができます。
アプリケーションの実行 パーマリンク to "アプリケーションの実行"
SecurityConfiguration.java
においてエンドポイントへのアクセスを許可します。
.antMatchers("/api/<appName>-kafka/publish").permitAll()
エンドポイントhttp://localhost:8080/api/<appName>-kafka/publish?message=...
を呼び出すと、コンソールにメッセージが記録されるはずです。