[Java知识库] Springboot集成消息队列kafka demo

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> Springboot集成消息队列kafka demo -> 正文阅读

[Java知识库]Springboot集成消息队列kafka demo

1.引入库

        <!-- kafka -->
        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>2.8.2</version>
        </dependency>

如果启动报错：Error creating bean with name ‘kafkaTemplate‘ defined in class path resource 那就是springboot版本和kafka不兼容去找对应版本兼容

2.配置文件

代码如下（示例）：

spring.kafka.bootstrap-servers=xxx:9092,xxx:9092,xxx:9092//接入点 kafka的环境ip
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.consumer.group-id=model  //消费者名字

示例代码

@Component
public class KafkaTest {

    @KafkaListener(topics = "model") //topic的名称
    public void kafkaConsume(String content){

        System.out.println("kafka消息消费："+content);

    }
}