Kafka消费者消息在指定的保留期之前被删除

6ljaweal  于 2022-09-21  发布在  Kafka
关注(0)|答案(1)|浏览(157)

所以我创建了一个Kafka主题,这些信息在短短24小时内就被删除了。我需要它保留到指定的时间retention.ms(28天)..以下是配置:

{
  "name": "foo",
  "partitions": 1,
  "replicas": 3,
  "retention": 2419200000,
  "cleanupPolicies": [
    "delete"
  ],
  "configuration": {
    "compression.type": "producer",
    "min.insync.replicas": "2",
    "message.downconversion.enable": "true",
    "segment.jitter.ms": "0",
    "cleanup.policy": "delete",
    "flush.ms": "9223372036854775800",
    "segment.bytes": "1073741824",
    "retention.ms": "2419200000",
    "flush.messages": "9223372036854775800",
    "message.format.version": "2.8-IV1",
    "max.compaction.lag.ms": "9223372036854775800",
    "file.delete.delay.ms": "60000",
    "max.message.bytes": "2000000",
    "min.compaction.lag.ms": "0",
    "message.timestamp.type": "CreateTime",
    "preallocate": "false",
    "index.interval.bytes": "4096",
    "min.cleanable.dirty.ratio": "0.5",
    "unclean.leader.election.enable": "true",
    "retention.bytes": "-1",
    "delete.retention.ms": "86400000",
    "segment.ms": "604800000",
    "message.timestamp.difference.max.ms": "9223372036854775800",
    "segment.index.bytes": "10485760"
  }
}
ugmeyewa

ugmeyewa1#

这是24小时

"delete.retention.ms": "86400000",

相关问题