嘿,
我们遇到了一个问题,在GCP自动化节点池升级过程中,当pod重新启动后,我们的Kafka集群上的一些pod会失去同步。我试图调查就绪探测器是否在Kafka完全同步和功能时进行测试,或者它是否在此之前报告就绪。
Kafka strimzy图像指向以下就绪探测器,但是进入pod并cat
-ing此文件只是空的?
exec:
command:
- test
- -f
- /var/opt/kafka/kafka-ready
failureThreshold: 3
initialDelaySeconds: 15
periodSeconds: 10
successThreshold: 1
timeoutSeconds: 5
1条答案
按热度按时间rxztt3cl1#
不可以,Strimzi中的就绪性检查不会检查整个集群是否同步。它检查Kafka代理是否准备好接受新连接。您可以使用Strimzi Drain Cleaner实用程序来帮助处理自愿驱逐,而不会破坏群集可用性。有关详细信息,请参阅https://strimzi.io/docs/operators/latest/full/deploying.html#rolling_pods_using_the_strimzi_drain_cleaner或https://github.com/strimzi/drain-cleaner