0
点赞
收藏
分享

微信扫一扫

大语言模型RAG-langchain models (二)

践行数据分析 03-15 10:30 阅读 2

删除Kafka自带Topic


一般情况下,你删除Kafka自带的__consumer_offsets topic,会报错提示不能删除。

倔强的你直接找到zookeeper删掉了它,list查看确实没有这个topic了,但是这会导致消费者和偏移量无法记录。


创建Kafka自带的Topic


如果尝试直接创建,不带参数,那么创建完成后,leader会显示none,ISR显示为空。

正确的创建方式是:

kafka-topics --create --zookeeper xxxx:2181 --replication-factor 3 --partitions 50 --topic __consumer_offsets --config cleanup.policy=compact --config min.compaction.lag.ms=86400000

保留期限可以自己调整,其他的参数不能变,否则不能被Kafka管理。


验证方式


  1. describe查看__consumer_offsets ,是否有leader、ISR
  2. 随便找一个topic(如topic_test,然后新建一个消费者
  3. 查看topic_test的消费者组,如果能查询出来,即为成功。

举报

相关推荐

0 条评论