Spring Boot Kafka 生产者示例

本示例旨在演示如何使用Spring Boot框架开发一个简单的Kafka生产者应用。

前置要求

• JDK 1.8或以上
• Kafka broker
• Maven

项目依赖

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

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

配置Kafka连接信息

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

spring.kafka.bootstrap-servers=your-kafka-broker-url:9092

需要将your-kafka-broker-url替换成你的Kafka broker的地址。

创建Kafka生产者

在Java类中创建一个Kafka生产者：

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

@Service
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

}

这里我们使用了Spring的依赖注入来注入一个KafkaTemplate对象。sendMessage()方法用于发送消息到Kafka。

发送消息

在需要发送消息的地方，注入Kafka生产者并调用sendMessage()方法：

@Autowired
private KafkaProducer kafkaProducer;

public void sendMessage() {
    kafkaProducer.sendMessage("Hello, Kafka!", "test_topic");
}

总结

在本示例中，我们演示了如何使用Spring Boot框架开发一个简单的Kafka生产者应用。通过学习本示例，你可以掌握如何配置Kafka连接信息、创建Kafka生产者以及发送消息到Kafka。

完整示例代码可以参考以下Github仓库：

https://github.com/example/spring-boot-kafka-producer