如何在 Go 中构建会话有序的 Kafka 管道

在 Go 中为实时对话 AI 平台构建 Kafka 消息层，用一致性哈希把同一会话的消息路由到固定 worker，再以每会话一个 goroutine 串行处理，从而在数千并发会话下保证会话内严格有序。系统已在生产处理超 4000 万条消息、未观察到乱序，测试中发送侧吞吐突破 100,000 条/秒。重试在会话 goroutine 内原地进行并配合指数退避，避免消息被后发消息超越。