phthon网站开发,产品设计开发公司,深圳电商app开发定制外包,南昌网站设计资讯删除Kafka自带Topic 一般情况下#xff0c;你删除Kafka自带的__consumer_offsets topic#xff0c;会报错提示不能删除。
倔强的你直接找到zookeeper删掉了它#xff0c;list查看确实没有这个topic了#xff0c;但是这会导致消费者和偏移量无法记录。 创建Kafka自带的Topi…删除Kafka自带Topic 一般情况下你删除Kafka自带的__consumer_offsets topic会报错提示不能删除。
倔强的你直接找到zookeeper删掉了它list查看确实没有这个topic了但是这会导致消费者和偏移量无法记录。 创建Kafka自带的Topic 如果尝试直接创建不带参数那么创建完成后leader会显示noneISR显示为空。
正确的创建方式是
kafka-topics --create --zookeeper xxxx:2181 --replication-factor 3 --partitions 50 --topic __consumer_offsets --config cleanup.policycompact --config min.compaction.lag.ms86400000保留期限可以自己调整其他的参数不能变否则不能被Kafka管理。 验证方式 describe查看__consumer_offsets 是否有leader、ISR随便找一个topic如topic_test然后新建一个消费者查看topic_test的消费者组如果能查询出来即为成功。
