在 Spring Boot 项目中整合 Kafka,你需要添加以下依赖:
- 在
pom.xml
文件中添加 Kafka 和 Spring Boot Kafka 相关的依赖:
org.springframework.boot spring-boot-starter-web org.springframework.kafka spring-kafka
- 在
application.properties
或application.yml
文件中配置 Kafka 相关属性:
# application.properties spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.consumer.group-id=my-group spring.kafka.consumer.auto-offset-reset=earliest spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
或
# application.yml spring: kafka: bootstrap-servers: localhost:9092 consumer: group-id: my-group auto-offset-reset: earliest key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer producer: key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer
这些依赖和配置将帮助你在 Spring Boot 项目中集成 Kafka。