【问题标题】:What happens to unprocessed messages in go channel on abrupt shutdown?突然关闭时 go 通道中未处理的消息会发生什么?
【发布时间】:2022-02-11 00:06:01
【问题描述】:

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

【问题讨论】:

  • 如果一个进程死掉了,它使用的所有内存通常都会被操作系统回收。
  • 你有没有提出过这个问题,或者这是一个假设的例子?

标签: go kubernetes goroutine kubernetes-hpa confluent-kafka-go


【解决方案1】:

仍然在 go channel 中未处理的消息会发生什么?

go 中的通道在内存中,所以当应用崩溃时,通道中的所有内容都会丢失。

【讨论】:

    猜你喜欢
    • 2011-08-19
    • 1970-01-01
    • 1970-01-01
    • 2021-09-28
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多