我想删除Kafka的主题 __Consumer_offset 因为这给我的经纪人带来了很多困惑。当我这么做的时候,它说这个主题不能被标记为删除。我正在使用zookeeper cli删除它,例如 rmr /brokers/topic __consumer_offset ,但它不起作用!
__Consumer_offset
rmr /brokers/topic __consumer_offset
pw136qt21#
__consumer_offsets 是Kafka内部主题,不允许通过delete topic命令删除。它包含关于每种类型的提交偏移量的信息topic:partition for 每组消费者(groupid)。如果你想彻底消灭它,你必须删除zookeeper dataDir 位置。这意味着,您将丢失所有元数据。另外,如果您只是想摆脱现有的消费群体,您也可以重置偏移量或考虑删除它们。
__consumer_offsets
dataDir
ltskdhd12#
恐怕你不能删除那个主题。它是一个内部主题,不应手动删除。如果必须这样做,则必须手动清理/删除数据目录。当您部署kafka代理和zookeers时,它会创建数据目录。注意:删除数据目录会丢失所有主题和相关数据。所以这在生产中是不可行的。
2条答案
按热度按时间pw136qt21#
__consumer_offsets
是Kafka内部主题,不允许通过delete topic命令删除。它包含关于每种类型的提交偏移量的信息topic:partition for 每组消费者(groupid)。如果你想彻底消灭它,你必须删除zookeeperdataDir
位置。这意味着,您将丢失所有元数据。另外,如果您只是想摆脱现有的消费群体,您也可以重置偏移量或考虑删除它们。
ltskdhd12#
恐怕你不能删除那个主题。它是一个内部主题,不应手动删除。
如果必须这样做,则必须手动清理/删除数据目录。当您部署kafka代理和zookeers时,它会创建数据目录。
注意:删除数据目录会丢失所有主题和相关数据。所以这在生产中是不可行的。