Как, какие символы не допускаются? Кажется, я ничего не могу найти.Каковы правила для именования тем Кафки (0.9)?
Нужно это для правильной проверки ошибок. Спасибо!
Как, какие символы не допускаются? Кажется, я ничего не могу найти.Каковы правила для именования тем Кафки (0.9)?
Нужно это для правильной проверки ошибок. Спасибо!
Глядя на source, это выглядит как ASCII alphanumerics, .
, _
и -
являются действительными символами в названии темы.
Это может быть полезно.
При выполнении команды --create
с якобы неправильным названием темы, Кафки командной строки бросает ошибку с действующими требованиями название темы как:
Команда:
[[email protected] ~]$ 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$)