kafkajs 不支持跳过消息体而只读取消息头，因为 kafka 协议中 headers 与 record 紧密绑定，必须完整拉取并解析记录才能访问 header 字段。
在 Kafka 中，消息（record）是一个原子单元：key、value 和 headers 均序列化后共同存储于同一日志段（log segment）中，并由 Broker 以完整批次（batch）形式返回给消费者。KafkaJS 作为客户端库，严格遵循 Kafka wire protocol —— 它无法在不反序列化整个 RecordBatch 的前提下提取 headers。这意味着：只要你想读 header，就必须“消费”该消息（即调用 eachMessage 或 eachBatch 并接收该 record 对象）。
这与 autoCommit: true/false 无关。自动提交控制的是 offset 提交行为，而非消息读取粒度。即使你设置 autoCommit: false 并手动跳过 message.value 处理，仍然需要接收并持有 message 对象（含 message.headers），此时该消息在语义上已被“消费”——只是你选择不处理其 payload。
✅ 正确做法示例（轻量级 header 检查）：
const { Kafka } = require('kafkajs')
const kafka = new Kafka({ brokers: ['localhost:9092'] })
const consumer = kafka.consumer({ groupId: 'header-checker' })
await consumer.connect()
await consumer.subscribe({ topic: 'my-topic', fromBeginning: false })
await consumer.run({
autoCommit: false, // 显式禁用自动提交，便于精确控制
eachMessage: async ({ topic, partition, message }) => {
// ✅ 可安全访问 headers，无需解析 value/key
console.log('Headers:', message.headers)
// 示例：根据 header 判断是否需触发下游流程
if (message.headers?.['processing-state'] === Buffer.from('pending')) {
await triggerExternalWorkflow(message.headers)
}
// ⚠️ 注意：仍需手动 commit，否则重复消费
await consumer.commitOffsets([{
topic,
partition,
offset: (parseInt(message.offset) + 1).toString()
}])
}
})⚠️ 关键注意事项：
- 不存在“只读 header”的网络层优化：Kafka 协议无类似 HTTP HEAD 请求的机制；所有 fetch 请求均返回完整 record。
- 性能影响可控：message.headers 是已解析的 JS 对象（Record.Headers 类型），message.value 和 message.key 默认为 Buffer，不调用 .toString() 或 JSON.parse() 就不会触发反序列化开销。
- 若业务逻辑仅依赖 header，建议：
- 使用独立 consumer group（如 header-router）避免干扰主业务流；
- 设置 readUncommitted: true（如需读取未提交事务消息）；
- 避免在 eachMessage 中执行阻塞操作，必要时使用 eachBatch 批量处理提升吞吐。
总结：这不是 KafkaJS 的功能缺失，而是 Kafka 架构的固有设计。所谓“不消费”，在 Kafka 语义中等价于“不拉取该 offset”，而 header 访问必然伴随拉取——因此，合理的设计是：让一个轻量 consumer 专职解析 header 并路由决策，主 consumer 专注业务处理，二者共享 topic 但隔离 concern。
