关注最新报道、解读和相关科技故事。
Joshua Oluikpe 介绍了一种实用设计，用于在每个会话内严格按顺序处理 Kafka 消息，同时让相互独立的会话能够并行运行。该设计依赖一致性哈希、每个会话一个 Go 工作者、在同一路径内重试，以及对连续提交点的管理，以避免崩溃后丢失消息。