可能是为了更好兼容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