如何删除名字中有空格的Kafka主题?例如,Kafka主题名为“测试主题”,我无法删除它。我收到一个名为topic的消息不存在,因为它试图搜索主题“test”。我们尝试对主题名使用双引号(“”),在空格前使用反斜杠()。两者都不起作用。我目前得到领导人不可用的重复性错误的主题,我必须删除Kafka中存在的所有主题,使稳定和重新启动。我需要帮助。有人吗??
kfgdxczn1#
例如,要匹配主题名称末尾的空格,
./bin/kafka-topics.sh --zookeeper $(hostname -f):2181 --describe --topic "topicname\\u0020"
我发现空白和java链接对于unicode很有用:空白匹配regex-java
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.
当试图删除这样一个奇怪的主题名时,这个技巧可能会成功,所以希望它能有所帮助。
2条答案
按热度按时间kfgdxczn1#
例如,要匹配主题名称末尾的空格,
我发现空白和java链接对于unicode很有用:空白匹配regex-java
xdyibdwo2#
您可以尝试使用regex表达式(如果您没有任何其他要持久化的test主题,请执行以下操作):
例如(这实际上是一个真实的测试):
当试图删除这样一个奇怪的主题名时,这个技巧可能会成功,所以希望它能有所帮助。