美文网首页
kafka生产者发消息的完整过程

kafka生产者发消息的完整过程

作者: M_lear | 来源:发表于2024-06-03 20:23 被阅读0次

前提:kafka使用默认的配置。

  1. 生产者初始化:生产者初始化后,向集群中任一broker请求元数据(配置、主题、分区leader等),并将元数据缓存到本地,后续会定期请求并更新本地的元数据。
  2. 查询主题元数据:向某个主题发送消息时,先本地查询主题元数据,如果主题不存在,向集群中任一broker请求主题的元数据,broker发现主题不存在,默认会创建主题并选举各分区leader,然后将主题元数据响应给生产者。
  3. 选择分区:生产者默认使用键哈希选择消息要发往主题下的哪个分区。
  4. 发消息:向分区的leader broker发消息。默认acks=1的情况下,当leader broker接收消息后会立即回复确认。

相关文章

  • kafka的基本框架概览

    Producer:消息生产者,向kafka broker发消息的客户端 Consumer:消息消费者,向kafka...

  • Kafka 生产者概述

    生产者:往消息队列里推送消息的应用 发送消息的过程 Kafka 生产者发送消息的过程: Kafka 会将发送消息包...

  • Kafka系列之(1)——Kafka概念和架构

    1、概念 Producer: 消息生产者,就是向kafka broker发消息的客户端。 Consumer: 消费...

  • Kafka系列之(1)——Kafka概念和架构

    1、概念 Producer:消息生产者,就是向kafka broker发消息的客户端。Consumer:消费消息。...

  • Kafka 消费者的分配策略

    这里要与 Kafka 生产者的分区规则区分开。 生产者的分区规则指的是:生产者在生产数据过程中,一个Topic有多...

  • kafka0.8

    1、Kafka分为:生产者(producer),消费者(consumer) 2、生产者提交消息,给Kafka集群,...

  • Kafka - 生产者初步学习

    Kafka - 生产者初步学习 一、kafka生产者组件 我们从创建一个 ProducerRecord 对象开始,...

  • Kafka生产者:写消息到Kafka

    本章我们将会讨论Kafka生产者是如何发送消息到Kafka的。Kafka项目有一个生产者客户端,我们可以通过这个客...

  • [kafka系列]之producer端消息发送

    本小节我们来讨论Kafka生产者是如何发送消息到Kafka的, Kafka项目有一个生产者客户端,我们可以通过这个...

  • Kafka生产者:写消息到Kafka

    本章我们将会讨论Kafka生产者是如何发送消息到Kafka的。Kafka项目有一个生产者客户端,我们可以通过这个客...

网友评论

      本文标题:kafka生产者发消息的完整过程

      本文链接:https://www.haomeiwen.com/subject/kcveqjtx.html