在Kafka分区中压缩的偏移量会发生什么变化?

wwodge7n  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(357)

假设,我有一个partion-0,有两个日志段。第一段包含偏移量0、1和2处的键v1、v2和v3。第二段在偏移量3、4和5处有键v3、v4、v1。
当日志压缩发生时,第一段中偏移量0和2处的键将被删除。
偏移量0和2会发生什么变化?它们变空了吗?如果是这样,那么这个空偏移量会发生什么变化?

dohp0rv5

dohp0rv51#

偏移与关键点(和值)一起消失。
偏移量就像一个唯一的标识符,在主题的生命周期中从不改变,并且总是属于同一条消息。

相关问题