换一个topic名称重新创建下,别的不用改,重新创建下就可以
创建topic时还会检测是否包含“.”或“”字符。为什么要检测这两个字符呢? 因为在 Kafka 的内部做埋点时会根据主题的名称来命名 metrics 的名称,并且会将点号“.”改成下画线 “"。假设遇到一个名称为“topic.1_2’’的主题,还有一个名称为“topic_1.2” 的主题,那么最后的 metrics 的名称都会为“topic_1_2”,这样就发生了名称冲突。举例如下, 首先创建一个以“topic.1_2”为名称的主题,提示 WARNING 警告, 之后再创建“topic.1_2” 时发生 InvalidTopicException 异常。