使用Kafka

細節

Kafka是一個流行的發布-訂閱訊息系統。JHipster對Kafka具有可選支援,它將:

  • 使用JHipster設定Kafka clients
  • application-*.yml檔案中新增必要的設定。
  • 生成Docker Compose設定檔案,只需輸入docker-compose -f src/main/docker/kafka.yml up -d,即可使用Kafka。

必備條件

生成一個新的應用程式,並確保在提示您要使用的技術時,選擇Asynchronous messages using Apache Kafka。 一個Docker Compose設定檔案將被生成,您可以使用以下指令啟動Kafka:

docker-compose -f src/main/docker/kafka.yml up -d

消費者和生產者

消費者(<appName>KafkaConsumer class) 正在執行,可以適應您的需求。 生產者(<appName>KafkaProducer class) 也是可用的,並且可以透過REST端點(<appName> KafkaResource class)進行呼叫。

執行應用

SecurityConfiguration.java設定中允許訪問的端點:

.antMatchers("/api/<appName>-kafka/publish").permitAll()

如果您呼叫端點http://localhost:8080/api/<appName>-kafka/publish?message=..., 則應該看到記錄到控制台的訊息。