我在 kubernetes 中部署了一个 go 应用程序。我的应用程序有一个 go 例程,它不断侦听来自 kafka 主题的消息,并将新消息推送到 go 通道以进行进一步处理并提交 kafka 消息。如果我使用 hpa 减少副本的数量/如果副本由于恐慌而下降,那么仍然在 go 通道中未处理的消息会发生什么?
问问题
66 次
我在 kubernetes 中部署了一个 go 应用程序。我的应用程序有一个 go 例程,它不断侦听来自 kafka 主题的消息,并将新消息推送到 go 通道以进行进一步处理并提交 kafka 消息。如果我使用 hpa 减少副本的数量/如果副本由于恐慌而下降,那么仍然在 go 通道中未处理的消息会发生什么?