本篇内容介绍了“Kafka是怎么保证分区有序的”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
Kafka只能保证分区有序,
如果只有一个分区,
那也是变向的全局有序
通过配置 max.in.flight.requests.per.connection = 1
这个配置是 生产者 往 服务度 发送数据的请求数,
配置为1,则一次只能发送1个请求,
如果失败继续重试,知道成功,
才会进行下一个请求的发送,
这样就保证了消息的有序性,
但是相对性能就大大降低了。
通过生产者幂等特性
幂等的保证是需要给每条消息加一个 Seqnum的,
也就是每个消息都有自己的序号,
服务端对于比当前最新的Seqnum大于1的消息,
是会拒绝的,
所以也可以保证消息的顺序性
“Kafka是怎么保证分区有序的”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。