Kafka是什么，以及如何使用SpringBoot对接Kafka_kafka对接(1)_kafka springboot对接

此时我们可以直接选择使用Apache Kafka，另外项目还可以加个Spring Web准备让前台调用

2. 添加Kafka依赖

如果你不是像上述一样新建的项目，那你也可以选择在已有的Spring Boot应用程序中使用Kafka，那么你需要在pom.xml文件中添加以下依赖：

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

1
2
3
4
5
6

3. 配置Kafka

在application.properties文件中添加以下配置：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=test_group

1
2
3

这里我们指定了Kafka服务器的地址和端口，并配置了消费者组的ID，关于消费者组的概念，其实就是某一些消费者具备相同的功能，因此会把他们设为同一个消费者组，这样他们就不会重复消费同一条消息了。更具体地原理，我们会在之后地篇章中介绍。

4. 创建Kafka生产者

在Kafka中，生产者是发送消息的应用程序或服务。在Spring Boot中，我们可以使用KafkaTemplate类来创建Kafka生产者

package com.zhanfu.kafkademo.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class KafkaService {
    
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String message) {
        kafkaTemplate.send("test\_
1
2
3
4
5
6
7
8
9
10
11
12
13