Kafka主题的命名规则是什么(0.9)?

nom7f22z  于 2021-06-08  发布在  Kafka
关注(0)|答案(2)|浏览(1479)

例如,哪些字符是不允许的?我好像到处都找不到这个。
需要它来执行正确的错误检查。谢谢您!

6gpjuf90

6gpjuf901#

从源代码看,它看起来像ascii字母数字, . , _ 以及 - 是主题名称中的有效字符。

z18hc3ub

z18hc3ub2#

这可能有用。
当你执行 --create 命令的主题名可能错误,kafka命令行会抛出错误,其中包含有效的主题名要求,如下所示:
命令:

[hduser@node1 ~]$  kafka-topics --zookeeper node1:2181 --create --topic time#test --partitions 1 --replication-factor 1

错误:

Error while executing topic command : topic name time#test is illegal, 
contains a character other than ASCII alphanumerics, '.', '_' and '-'
[2016-07-13 23:31:02,513] ERROR org.apache.kafka.common.errors.InvalidTopicException: 
topic name time#test is illegal, 
contains a character other than ASCII alphanumerics, '.', '_' and '-'
(kafka.admin.TopicCommand$)

相关问题