可能是为了更好兼容kafka的命名规则吧。
kafak的命名规则:
- 由大小写字母、数字、
.
、-
、_
组成 - 不能为空、不能为
.
、不能为..
- 长度不能超过249
虽然topic可以含有点(.),但是实际在创建的时候,kafka会把点(.)替换成下划线(_)存储到zk中。但是如果碰到这种情况就会有问题:topic.A_B 和topic_A.B,最终会报topic冲突,因为两者最终的存储是topic_A_B
可能是为了更好兼容kafka的命名规则吧。
kafak的命名规则:
.
、 -
、 _
组成.
、不能为 ..
虽然topic可以含有点(.),但是实际在创建的时候,kafka会把点(.)替换成下划线(_)存储到zk中。但是如果碰到这种情况就会有问题:topic.A_B 和topic_A.B,最终会报topic冲突,因为两者最终的存储是topic_A_B