Hello Xiaochi ,
I am not sure if I have understood the problem correctly but beware the
fact that only old log segments and not the current log segment are
taken into account for deletions. So if you want the data to be deleted
in a timely manner, you also need to configure a tighter interval
Hello,
I am currently using kafka 3.1.0 with java 1.8. I have set kafka log
retention policy in the server.properties like this:
log.retention.hours=6
log.retention.bytes=5368709120
log.segment.bytes=1073741824
log.retention.check.interval.ms=30
log.cleanup.policy=delete
However, it see
