kafka日志压缩频繁更新的密钥永远不会被使用

n6lpvg4x  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(217)

基于Kafka文献https://kafka.apache.org/documentation/#compaction

基于偏移量的客户消费顺序:
压实前为k1、k2、k3、k4、k5、k6和
压实后变为k1、k3、k4、k5、k2、k6
所以我说的对吗(如果我们有相对较小的压缩间隔)如果我们让k2一直进入主题(以及其他键,比如说不重复,k100,k101,k102等等),它会一直被推后,如果我们有一个消费者比生产者慢,在k2赶上生产商的速度之前,消费者是不会消费k2的?
如果上面的陈述是真的,我们是否有一种方法来配置这种行为,比如消耗的顺序与压缩前相同,但是k2的值是最新的。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题