Spring Boot 连接 Kafka 消息服务器：入门指南

以下是一个简单的 Spring Boot 应用程序，用于连接 Kafka 消息服务器并发送和接收消息。

添加依赖

在 pom.xml 文件中添加以下依赖：

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

配置 Kafka

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

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

创建生产者

创建一个 Kafka 生产者，用于发送消息到 Kafka 消息服务器：

@Service
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

创建消费者

创建一个 Kafka 消费者，用于从 Kafka 消息服务器接收消息：

@Service
public class KafkaConsumer {

    @KafkaListener(topics = "${spring.kafka.topic}")
    public void receiveMessage(String message) {
        System.out.println('Received message: ' + message);
    }
}

发送消息

在需要发送消息的地方，注入 KafkaProducer 并调用 sendMessage 方法：

@Autowired
private KafkaProducer kafkaProducer;

public void send() {
    kafkaProducer.sendMessage('my-topic', 'Hello, Kafka!');
}

运行应用程序

运行 Spring Boot 应用程序并查看控制台输出，以确保消息已成功发送和接收。

以上就是连接 Kafka 消息服务器的简单示例代码。当然，实际应用程序需要更多的配置和处理逻辑。