必须用try/catch(ConsumeException)包裹Consume()并监听OnError判断IsFatal来终止循环；AutoOffsetReset.Earliest仅在无有效offset时生效；EnableAutoCommit=false时需在业务成功且持久化后立即Commit；Key应设为Ignore而非null。
Consume() 必须包在 try/catch(ConsumeException) 里吗？
必须。这不是容错建议，是保活底线。
Consume() 是阻塞调用，但底层网络抖动、SASL 认证过期、broker 主从切换、甚至 DNS 解析失败，都会直接抛出 ConsumeException，而不是返回 null 或等待超时。不捕获会导致消费者线程静默退出，整个消费循环中断——线上表现为“消息突然停收”，且无任何异常日志。
更关键的是 fatal 错误（如 GroupAuthorizationFailed、UnknownTopicOrPartition）：它们只抛一次，之后 consumer 内部状态已损坏，但 Consume() 仍会继续调用，陷入无效重试循环。必须监听 c.OnError 并主动终止循环：
consumer.OnError += (_, e) => {
if (e.IsFatal) consuming = false;
Console.WriteLine($"Kafka error: {e.Reason}");
};- 漏掉
OnError监听，fatal 错误后 consumer 会卡死，Consume()持续返回空或重复报错 - 仅靠
try/catch不够，IsFatal是唯一可靠判断依据 - 不要用
Thread.Sleep等待恢复——状态已不可逆，必须重建 consumer 实例
AutoOffsetReset.Earliest 为什么没从头消费？
因为它只在 consumer group 没有有效 offset 时生效，不是“每次启动都重放”。
常见误判是设了 AutoOffsetReset.Earliest 就以为能反复拉取历史消息。实际行为是：
- 首次订阅 topic、group 被手动删除（
kafka-consumer-groups.sh --delete）、或 offset 过期（默认offsets.retention.minutes=168）后，才会触发 Earliest 行为 - Earliest 拉取的是“当前保留窗口内最早的消息”，不是 topic 创建以来所有消息（Kafka 默认只保留 7 天）
- 只要 group 曾成功 commit 过 offset，后续启动永远从上次位置继续
真想重放？得删 group，或在已有 consumer 上调用 consumer.Unsubscribe() + consumer.Subscribe() 后手动 Seek() 到指定 offset。
EnableAutoCommit = false 时，Commit() 该在哪儿调用？
必须在业务逻辑执行成功、且结果已持久化（如 DB 写入确认）后立即调用 consumer.Commit(cr)。
commit 太早（比如刚收到就 commit）＝消息处理失败后无法重试；commit 太晚（比如攒 100 条再 commit）＝进程崩溃最多丢 100 条。折中建议：
- 单条处理完即 commit：适合对一致性要求极高、吞吐压力不大的场景
- 每 5–10 条批量 commit：需配合
consumer.Commit()传入offsets数组，避免 offset 跳变 - 绝不在循环外统一 commit：容易漏掉最后一批未 commit 的消息
注意：Commit() 是同步阻塞调用，频繁调用会影响吞吐；但比丢消息或重复消费代价小得多。
ConsumerBuilder 构造时，Key 用 Ignore 还是 null？
用 Ignore。这是安全边界问题，不是风格偏好。
Ignore 表示“跳过 key 反序列化”，即使 broker 发来非空 key 也不会崩溃；而 null（即 ConsumerBuilder<null, string>）会尝试把 key 反序列化为 C# 的 null 引用，一旦 broker 实际发了非空 key，就会在反序列化阶段直接抛 SerializationException。
绝大多数业务并不读取 cr.Key，比如日志上报、事件通知、无状态任务分发——这种场景下，Ignore 是唯一合理选择：
- 显式声明“我不关心 key”，避免意外反序列化失败
- 和生产者端是否发送 key 完全解耦，降低上下游协同成本
- 性能略优：少一次反序列化开销
只有当你明确需要基于 key 做分区路由、去重、或下游消费者依赖 key 时，才用 ConsumerBuilder<string, string>，并确保 key 永远非 null。
