如何删除名字中有空格的Kafka主题?

uqjltbpv  于 2021-06-04  发布在  Kafka
关注(0)|答案(2)|浏览(441)

如何删除名字中有空格的Kafka主题?
例如,Kafka主题名为“测试主题”,我无法删除它。我收到一个名为topic的消息不存在,因为它试图搜索主题“test”。
我们尝试对主题名使用双引号(“”),在空格前使用反斜杠()。两者都不起作用。我目前得到领导人不可用的重复性错误的主题,我必须删除Kafka中存在的所有主题,使稳定和重新启动。我需要帮助。有人吗??

kfgdxczn

kfgdxczn1#

例如,要匹配主题名称末尾的空格,

./bin/kafka-topics.sh --zookeeper $(hostname -f):2181 --describe --topic "topicname\\u0020"

我发现空白和java链接对于unicode很有用:空白匹配regex-java

xdyibdwo

xdyibdwo2#

您可以尝试使用regex表达式(如果您没有任何其他要持久化的test主题,请执行以下操作):

./bin/kafka-topics.sh --zookeeper zooHost:2181 --delete --topic 'test*'

例如(这实际上是一个真实的测试):

./bin/kafka-topics.sh --zookeeper localhost:2181 --create 
--topic zzzzz --replication-factor 1 --partitions 1
Created topic zzzzz.
 ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic 'zzz*'
Topic zzzzz is marked for deletion.

当试图删除这样一个奇怪的主题名时,这个技巧可能会成功,所以希望它能有所帮助。

相关问题