测试是否准备就绪Kafka，可以从CLI中找到主题

Question

环顾四周，除了kafka-topic-list-list。我正在K8S环境中运行Kafka，并设有一个创建几个主题的初始容器。我希望我的主要容器仅在创建主题时才开始，并且主题是"可订阅"的。kafka-topic-我相信名单列表刚刚到达Zookeeper，因为我可以看到我的吊舱正在显示有关该主题的错误消息。

我确实尝试了Kafka-Console-Consumer，但是即使主题不存在，也不会以状态1退出。我正在寻找类似于下面的解决方案

kafka-console-consumer --bootstrap-server correct-bootstrap-server:9092 --topic correct-topic --timeout-ms 100

用0(此操作(退出

kafka-console-consumer --bootstrap-server wrong-bootstrap-server:9092 --topic wrong-topic --timeout-ms 100

使用非零退出代码退出(这也有效(。

kafka-console-consumer --bootstrap-server correct-bootstrap-server:9092 --topic wrong-topic --timeout-ms 100

使用非零退出代码退出(该代码使用代码0不起作用(

谢谢。

Answer 1

如果KAFKA主题为"准备就绪"，请确保从CLI确保并不是完全微不足道的。很多事情可能会出错。

我们遇到了相同的问题，我们正在采用的当前方法涉及到卡夫卡 - 主题CLI

1. 我们确保主题与kafka-topics.sh --describe --topic FOO
存在
2. 检查所有分区是否具有领导者kafka-topics.sh --describe --topic FOO --unavailable-partitions(输出应为空(
3. 检查所有分区是否已完全复制kafka-topics.sh --describe --topic FOO --under-replicated-partitions(输出应为空(

仍然没有100％确定该主题为"准备就绪"，但对我们有用

Answer 2

kafka-topics可以列出未复制的，离线和米内ISR分区。最好的选择是检查您的主题是否不足。如果还没有，应该准备就绪。