在 WriteMessages 返回上下文超时错误后传递的消息
作者: ionutboangiu创建于 2026年3月13日更新于 2026年3月13日
我正在调用 `WriteMessages`,并设置了上下文超时。当代理不可达时,上下文会过期,我会收到错误,这并没有问题。问题在于这些消息在代理恢复后仍会被交付。每一条消息都会如此。
内容来源: segmentio/kafka-go
我正在调用 `WriteMessages`,并设置了上下文超时。当代理不可达时,上下文会过期,我会收到错误,这并没有问题。问题在于这些消息在代理恢复后仍会被交付。每一条消息都会如此。
内容来源: segmentio/kafka-go