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

4

具体来说,哪些字符是不允许的?我在任何地方都找不到相关信息。

我需要这个信息来实施适当的错误检查。谢谢!


对于kafka 1.10 / 1.11,请参考以下问题:https://dev59.com/p1oU5IYBdhLWcg3w1pT2 - tsh
2个回答

4

源代码可以看出,主题名称中可以使用ASCII字母数字、._-这些字符。


0

这可能会有用。

当您使用错误的主题名称执行--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$)

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接