在apache kafka中,如何在不删除topic的情况下删除_schemas topic的内容?
In apache kafka, how can we delete the content of _schemas topic without deleting the topic?
在 apache kafka 中,是否有任何选项可以在不删除主题且不将保留期更改为 1 秒的情况下删除 _schemas 主题的内容?
好吧,主题本身设置为 cleanup.policy=compact
,因此保留不适用。
如果你想要一个空的主题,你应该用不同的 kafkastore.topic
重新启动 Registry 来创建一个新的
否则,设置cleanup.policy=compact,delete
,然后log.retention.ms=100
之类的东西将清理主题
跟进 @cricket_007 的回答,Kafka 内部主题 __consumer_offsets 和 _schemas 默认具有紧凑的清理策略。
如果你想改变配置只是为了删除,你可以使用./kafka-topics.sh --zookeeper <host>:2181 --topic _schemas --alter --config cleanup.policy=delete
虽然两者都很紧凑,但建议删除策略。
在 apache kafka 中,是否有任何选项可以在不删除主题且不将保留期更改为 1 秒的情况下删除 _schemas 主题的内容?
好吧,主题本身设置为 cleanup.policy=compact
,因此保留不适用。
如果你想要一个空的主题,你应该用不同的 kafkastore.topic
重新启动 Registry 来创建一个新的
否则,设置cleanup.policy=compact,delete
,然后log.retention.ms=100
之类的东西将清理主题
跟进 @cricket_007 的回答,Kafka 内部主题 __consumer_offsets 和 _schemas 默认具有紧凑的清理策略。
如果你想改变配置只是为了删除,你可以使用./kafka-topics.sh --zookeeper <host>:2181 --topic _schemas --alter --config cleanup.policy=delete
虽然两者都很紧凑,但建议删除策略。