在springboot中对kafka进行读写的示例代码

下面是关于在Spring Boot中对Kafka进行读写的完整攻略。

准备工作

在开始示例前，我们需要准备一些必要的工作：

1. 安装Kafka并启动服务
2. 在Spring Boot项目的pom.xml中加入Kafka依赖：

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

示例一：生产者

下面是一个简单的Kafka生产者示例代码：

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

@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

在上面的代码中，我们使用了Spring Boot提供的KafkaTemplate类来发送消息。需要注意的是，在使用KafkaTemplate时，我们需要指定key和value的类型，这里我们使用的是String类型。

示例二：消费者

下面是一个简单的Kafka消费者示例代码：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "test")
    public void receive(String message) {
        System.out.println("received message: " + message);
    }
}

在上面的代码中，我们使用了Spring Boot提供的@KafkaListener注解来监听指定的主题（topic）并接收消息。需要注意的是，KafkaListener注解支持的参数非常多，如：消费组、消息反序列化器、线程池等等。具体如何使用可以参考官方文档。

总结

通过上面的两个示例代码，我们可以看到，在Spring Boot中使用Kafka进行消息读写非常简单。Spring Boot和Kafka的集成提供了对完整的Kafka API的支持，可以轻松满足大多数场景的需求。