我有一个在 AWS MSK 上运行的 Kafka 集群，Kafka 生产者和消费者 go 客户端在 kubernetes 中运行。生产者负责将数据流发送到 Kafka。我需要帮助解决以下问题:
比方说，生产者代码中有一些代码更改，必须在 kubernetes 中重新部署它。我怎样才能做到这一点？由于数据是连续生成的，我不能简单地停止已经运行的生产者并部署更新的生产者。在这种情况下，我将在更新过程之间丢失数据。
有时由于代码中的 panic(golang)，客户端崩溃，但由于它作为 pod 运行，kubernetes 会重新启动它。我无法理解这是好事还是坏事。
谢谢
最佳答案
对于您的第一个问题，我建议您对集群中的部署进行滚动更新。
其次，这是 kubernetes 中部署的一般行为。我可以想到一个外部监控解决方案，它可以在出现 panic 时取消部署您的应用程序或停止处理请求。
如果你能解释为什么你需要这种行为会更好。!
关于go - 在 kubernetes 中处理 kafka 客户端更新，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56354566/