我有一个kafka集群在aws-msk上运行，kafka生产者和消费者go客户端在kubernetes上运行。制作人负责将数据流发送给Kafka。我需要帮助解决以下问题：
比方说，生产者代码中有一些代码更改，必须在kubernetes中重新部署它。我该怎么做？由于数据是连续生成的，我不能简单地停止已经运行的producer并部署更新的producer。在这种情况下，我将在更新进程之间丢失数据。
有时由于代码中的恐慌（golang），客户机崩溃，但是由于它作为pod运行，kubernetes重新启动它。我不知道这是好事还是坏事。
谢谢