开发者社区> 问答> 正文

Kafka的生产消费基本流程是怎样的?

Kafka的生产消费基本流程是怎样的?

展开
收起
花开富贵111 2024-05-23 16:47:09 8 0
1 条回答
写回答
取消 提交回答
  • Kafka的生产消费基本流程包括以下几个步骤:
    首先,Producer创建时会创建一个Sender线程并设置为守护线程;
    然后,生产的消息会经过拦截器、序列化器、分区器的处理,并缓存在缓冲区;
    接着,当缓冲区数据大小达到batch.size或者linger.ms达到上限时,会进行批次发送;
    发送的消息会落盘到指定的broker分区,根据配置的acks参数确认消息是否发送成功;
    如果生产者配置了retries参数大于0且未收到确认,会进行消息重试;
    消息成功落盘后,broker会返回生产元数据给生产者。

    2024-05-23 16:58:31
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载