Hi All,

We are using AWS MSK with kafka version 2.6.1. There is a compacted topic
with the below configurations. After reading the documentation my
understanding was that null values in the topic can be removed using delete
retention time but I can see months old keys having null values. Is there
any other configuration that needs to be changed for removing null values
from a compacted topic? Thanks!

cleanup.policy=compact
segment.bytes=1073741824
min.cleanable.dirty.ratio=0.1
delete.retention.ms=3600000
segment.ms=3600000

Regards,
Navneeth

Reply via email to