springbootkafka发送消息（springboot kafka配置参数）

by intanet.cn ca 大数据 on 2024-11-28

## Spring Boot Kafka 发送消息

简介

Apache Kafka 是一个分布式流处理平台，常用于构建高吞吐量、低延迟的实时数据管道。Spring Boot 提供了强大的集成支持，使得在 Spring Boot 应用中使用 Kafka 变得非常便捷。本文将详细介绍如何在 Spring Boot 应用中发送消息到 Kafka 主题。

一、项目配置

添加依赖

在 `pom.xml` 文件中添加 Spring Kafka 依赖：```xmlorg.springframework.kafkaspring-kafka```2.

配置 Kafka 属性

在 `application.properties` 或 `application.yml` 文件中配置 Kafka 连接信息：```propertiesspring.kafka.bootstrap-servers=localhost:9092 # Kafka Broker 地址spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer # Key 序列化器spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer # Value 序列化器# 其他生产者配置，例如：# spring.kafka.producer.acks=all# spring.kafka.producer.retries=0# spring.kafka.producer.batch-size=16384# spring.kafka.producer.linger.ms=1# spring.kafka.producer.buffer-memory=33554432# spring.kafka.producer.compression-type=none```或```yamlspring.kafka:bootstrap-servers: localhost:9092producer:key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializer# 其他生产者配置# acks: all# retries: 0# batch-size: 16384# linger.ms: 1# buffer-memory: 33554432# compression-type: none```

二、发送消息

使用 `KafkaTemplate`

`KafkaTemplate` 是 Spring Kafka 提供的核心类，用于发送消息。```javaimport org.springframework.beans.factory.annotation.Autowired;import org.springframework.kafka.core.KafkaTemplate;import org.springframework.stereotype.Service;@Servicepublic class KafkaProducer {@Autowiredprivate KafkaTemplate kafkaTemplate;public void sendMessage(String topic, String key, String message) {kafkaTemplate.send(topic, key, message);}// 异步发送并处理结果public void sendMessageAsync(String topic, String key, String message) {kafkaTemplate.send(topic, key, message).addCallback(result -> System.out.println("Message sent successfully: " + result.getRecordMetadata()),ex -> System.err.println("Failed to send message: " + ex.getMessage()));}// 同步发送public void sendMessageSync(String topic, String key, String message) {try {kafkaTemplate.send(topic, key, message).get(); // get() method waits for acknowledgementSystem.out.println("Message sent successfully");} catch (Exception e) {System.err.println("Failed to send message: " + e.getMessage());}}}```2.

在Controller中调用

```javaimport org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.

;@RestControllerpublic class KafkaController {@Autowiredprivate KafkaProducer kafkaProducer;@PostMapping("/send")public String sendMessage(@RequestParam String topic, @RequestParam String key, @RequestParam String message) {kafkaProducer.sendMessage(topic, key, message);return "Message sent successfully";}}```

三、序列化

上述示例使用了 `StringSerializer` 序列化 key 和 value。如果需要发送其他类型的数据，例如 JSON 对象，需要使用相应的序列化器，例如 `JsonSerializer`。你需要添加相应的依赖，例如 `jackson-databind`。

四、其他配置

可以根据实际需求配置其他生产者参数，例如 `acks`、`retries`、`batch-size` 等，以调整生产者的性能和可靠性。这些参数在上面的配置示例中已经注释说明。

总结

本文介绍了如何在 Spring Boot 应用中使用 `KafkaTemplate` 发送消息到 Kafka 主题，并涵盖了配置、序列化和异步发送等方面。 Spring Boot 简化了 Kafka 的集成，使得开发者可以更加便捷地使用 Kafka 进行消息传递。通过理解这些基本概念和配置，您可以轻松地构建基于 Kafka 的消息系统。

Spring Boot Kafka 发送消息**简介**Apache Kafka 是一个分布式流处理平台，常用于构建高吞吐量、低延迟的实时数据管道。Spring Boot 提供了强大的集成支持，使得在 Spring Boot 应用中使用 Kafka 变得非常便捷。本文将详细介绍如何在 Spring Boot 应用中发送消息到 Kafka 主题。**一、项目配置**1. **添加依赖**在 `pom.xml` 文件中添加 Spring Kafka 依赖：```xmlorg.springframework.kafkaspring-kafka```2. **配置 Kafka 属性**在 `application.properties` 或 `application.yml` 文件中配置 Kafka 连接信息：```propertiesspring.kafka.bootstrap-servers=localhost:9092

Kafka Broker 地址spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer

Key 序列化器spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

Value 序列化器

其他生产者配置，例如：

spring.kafka.producer.acks=all

spring.kafka.producer.retries=0

spring.kafka.producer.batch-size=16384

spring.kafka.producer.linger.ms=1

spring.kafka.producer.buffer-memory=33554432

spring.kafka.producer.compression-type=none```或```yamlspring.kafka:bootstrap-servers: localhost:9092producer:key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializer

其他生产者配置

acks: all

retries: 0

batch-size: 16384

linger.ms: 1

buffer-memory: 33554432

compression-type: none```**二、发送消息**1. **使用 `KafkaTemplate`**`KafkaTemplate` 是 Spring Kafka 提供的核心类，用于发送消息。```javaimport org.springframework.beans.factory.annotation.Autowired;import org.springframework.kafka.core.KafkaTemplate;import org.springframework.stereotype.Service;@Servicepublic class KafkaProducer {@Autowiredprivate KafkaTemplate kafkaTemplate;public void sendMessage(String topic, String key, String message) {kafkaTemplate.send(topic, key, message);}// 异步发送并处理结果public void sendMessageAsync(String topic, String key, String message) {kafkaTemplate.send(topic, key, message).addCallback(result -> System.out.println("Message sent successfully: " + result.getRecordMetadata()),ex -> System.err.println("Failed to send message: " + ex.getMessage()));}// 同步发送public void sendMessageSync(String topic, String key, String message) {try {kafkaTemplate.send(topic, key, message).get(); // get() method waits for acknowledgementSystem.out.println("Message sent successfully");} catch (Exception e) {System.err.println("Failed to send message: " + e.getMessage());}}}```2. **在Controller中调用**```javaimport org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.*;@RestControllerpublic class KafkaController {@Autowiredprivate KafkaProducer kafkaProducer;@PostMapping("/send")public String sendMessage(@RequestParam String topic, @RequestParam String key, @RequestParam String message) {kafkaProducer.sendMessage(topic, key, message);return "Message sent successfully";}}```**三、序列化**上述示例使用了 `StringSerializer` 序列化 key 和 value。如果需要发送其他类型的数据，例如 JSON 对象，需要使用相应的序列化器，例如 `JsonSerializer`。你需要添加相应的依赖，例如 `jackson-databind`。**四、其他配置**可以根据实际需求配置其他生产者参数，例如 `acks`、`retries`、`batch-size` 等，以调整生产者的性能和可靠性。这些参数在上面的配置示例中已经注释说明。**总结**本文介绍了如何在 Spring Boot 应用中使用 `KafkaTemplate` 发送消息到 Kafka 主题，并涵盖了配置、序列化和异步发送等方面。 Spring Boot 简化了 Kafka 的集成，使得开发者可以更加便捷地使用 Kafka 进行消息传递。通过理解这些基本概念和配置，您可以轻松地构建基于 Kafka 的消息系统。

关于vscode+clangd的信息 docker应用推荐（docker应用实例）