文章目录

• 1.概述

1.概述

我搭建集群 遇到这个问题 另外两个kafka节点 offsets.topic.replication.factor 都设置的3 都没报错

查看报错的位置是代码

/**
    * 这里主要创建内部的topic
    * 1.内置topic:  __consumer_offsets
    * 2. 事务topic: __transaction_state
    * @param topic
    * @return
    */
  private def createInternalTopic