在使用springboot集成kafka的时候需要注意springboot版本、引用的依赖spring-kafka版本和kafka中间件版本的对应关系,否则可能会因为版本不兼容导致出现错误。
org.springframework.kafka spring-kafka2.6.8
org.springframework.integration spring-integration-kafka3.3.0.RELEASE
Spring for Apache Kafka的官网地址如下:
在项目中应用时需要根据具体的环境,若项目采用springboot框架,则可以直接引用spring-kafka依赖,选择对应的依赖版本和kafka中间件版本即可。若项目为普通项目,则可以直接引用kafka-clients依赖,如下
org.apache.kafka kafka-clients3.1.0
上一篇:MySQL与Kafka数据库集成