kafka生产者异步发送、同步发送、回调异步发送，是什么情况？

Bertha 。 2024-03-17 23:28 96阅读 0赞

#### 目录标题 ####

*  一、异步发送
 *  二、同步发送
 *  三、回调异步发送

**Kafka是一种分布式流处理平台**，它是一种高吞吐量、可扩展、可持久化的消息队列系统，用于处理和存储实时流式数据。

Kafka基于发布-订阅模式，采用了分布式、多副本、分区的架构。它允许生产者将数据以消息的形式发送到Kafka集群的一个或多个主题(topic)中，而消费者可以从这些主题中订阅并获取数据。每个主题可以被分为多个分区(partition)，每个分区可以在多个服务器上进行副本(replica)以实现高可用性和容错性。

**Kafka具有以下几个主要特点**：

*  高吞吐量：Kafka采用了顺序磁盘写入和批量发送等优化策略，能够支持大规模数据的高吞吐量处理。
 *  可扩展性：Kafka的分布式架构和分区机制使得它能够轻松地水平扩展，以适应日益增长的数据流量。
 *  持久性：Kafka将消息持久化存储在磁盘上，保证数据不会丢失。
 *  容错性：Kafka通过将数据分散到多个服务器上的多个副本来实现容错，即使某个节点故障，仍然能够继续正常运行。
 *  实时处理：Kafka支持实时处理和流式计算，能够将大规模数据流实时传输给不同的数据处理系统。

Kafka在很多场景中都有广泛应用，特别是在大数据领域和实时数据处理方面，如日志收集、数据管道、实时流处理、在线分析等。

![在这里插入图片描述][f59d6caec159458d80667591f412cc70.png]

## 一、异步发送 ##

Kafka的生产者异步发送指的是在发送消息到Kafka集群时，并不等待服务器的响应，而是继续发送下一个消息。这样可以提高发送消息的吞吐量。以下是使用Java编写的Kafka生产者异步发送的示例代码：

import org.apache.kafka.clients.producer.*;
    
    import java.util.Properties;
    
    public class KafkaProducerAsyncExample {
       
        
    
        public static void main(String[] args) {
       
        
            // 设置Kafka生产者的配置属性
            Properties properties = new Properties();
            properties.put("bootstrap.servers", "localhost:9092");
            properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    
            // 创建Kafka生产者
            KafkaProducer<String, String> producer = new KafkaProducer<>(properties);
    
            // 发送多条消息
            for (int i = 0; i < 10; i++) {
       
        
                // 创建消息对象
                ProducerRecord<String, String

[f59d6caec159458d80667591f412cc70.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/530f57b5aa624a6f91b58fa52728b813.png