springboot 部署kafka 生产和消费

Spring Boot 是一个开源框架，可以让开发者快速创建基于 Spring 框架的应用程序。而 Kafka 是一个高吞吐量的分布式消息队列系统。下面是 Spring Boot 部署 Kafka 生产和消费的一般步骤：

1. 首先，需要在 Spring Boot 项目的 Maven 或 Gradle 构建文件中添加 Kafka 相关依赖。

2. 配置 Kafka 的生产者和消费者，包括主题、分区等参数。这些参数可以在 application.properties 或 application.yml 文件中配置。

3. 在生产者中发送消息，可以使用 KafkaTemplate 类来发送消息到指定的主题。消费者通过使用 @KafkaListener 注解来监听指定的主题，并处理接收到的消息。

4. 在代码中使用 Kafka 相关的 API 来实现生产者和消费者逻辑。具体操作可以参考 Spring Boot 官方文档或者 Kafka 官方文档。

下面是相关的代码片段：

1. 添加依赖（以 Maven 为例）：

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

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

spring.kafka.bootstrap-servers=localhost:9092
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.group-id=test-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

3. 在生产者中发送消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

4. 在消费者中监听并处理消息：

@KafkaListener(topics = "test-topic")
public void receiveMessage(String message) {
    // 处理接收到的消息
}