栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Kafka生产者对于消息顺序性的最佳实践

Kafka生产者对于消息顺序性的最佳实践

Kafka可以保证消息在一个Partition分区内的顺序性。如果生产者按照顺序发送消息,Kafka将按照这个顺序将消息写入分区,消费者也会按照同样的顺序来读取消息(通过自增偏移量)。

  • 如何保证消息按顺序发送到Kafka-broker?

  • kafka生产者有很多可配置项,这给kafka调优带来了一定的空间。其中,会影响消息顺序性投递的因素有

    • retries: 消息投递失败重试次数

    • max.in.flight.requests.per.connection: 生产者在收到kafka响应之前可以投递多少个消息

# 消息的顺序在什么情况下会产生问题
  • 当retries > 0重试次数大于0且max.in.flight.requests.per.connection > 1会发生:前面一批次消息写入失败,后面一批次的消息写入成功,重试之后,前面一批次的消息写入成功,那么消息的顺序就产生了问题。

# 如何保证消息顺序性
  1. 可以把retries设置为0 ,不重试,那么消息肯定是有序的,只不过存在消息投递失败丢失的情况。

  2. 将max.in.flight.requests.per.connection设置为1,在接收到Kafka响应之前,只允许一个批次的消息处于投递中的状态,这当然会严重影响Kafka的吞吐量。


  • 最佳实践:通常情况下,保证消息不丢失还是更为重要的考量,牺牲吞吐量还是次要的。

  • 推荐配置:retries>0; max.in.flight.requests.per.connection=1

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/422487.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号