kafka consumer 通过 consumerrecords 天然支持多 topic 混装消息处理：一次 poll() 返回的记录可跨多个 topic，每条 consumerrecord 自带 topic/partition/offset 信息；订阅只需 subscribe(topic 列表)，客户端自动均衡分区；遍历时可通过 record.topic() 或 records.records("topic") 按 topic 分发；手动提交 offset 需显式构造 topicpartition 映射；反序列化器须兼容所有 topic 的消息格式。
Java 中 Kafka Consumer 用 ConsumerRecords<k v></k> 处理多 Topic 混装消息，核心在于：它本身天然支持混装——ConsumerRecords 是按 Topic + Partition 分组的容器，一次 poll() 返回的所有记录可能来自多个 Topic，且每条 ConsumerRecord 都自带 record.topic()、record.partition() 和 record.offset()，无需额外拆包或路由判断。
订阅多个 Topic 很直接
只需在 subscribe() 时传入 Topic 名列表，Kafka 客户端自动完成分区分配与拉取：
consumer.subscribe(Arrays.asList("order-topic", "user-topic", "log-topic"));- 不需手动管理分区，消费者组内自动均衡各 Topic 的分区（只要这些 Topic 分区数总和 ≥ 消费者实例数）
- 注意：不能混用
subscribe()和assign()；多 Topic 场景必须用subscribe
从 ConsumerRecords 中区分并分发消息
ConsumerRecords<string string></string> 不是扁平列表，而是 Map<topicpartition list>>></topicpartition> 的封装。遍历时建议按 Topic 归类处理：
- 遍历所有 record：
for (ConsumerRecord<string string> record : records)</string>，再用record.topic()判断来源 - 或先按 Topic 聚合：
records.records("order-topic")获取该 Topic 的所有记录（返回List<consumerrecord></consumerrecord>） - 常见做法：用
switch(record.topic())或if-else if分支做业务路由，避免类型强耦合
Offset 提交要留意 Topic 粒度
手动提交时，commitSync() 或 commitAsync() 默认提交当前 poll 返回的所有分区 offset —— 包含多个 Topic 的混合 offset。若只想提交某 Topic 的进度，需显式构造 Map<topicpartition offsetandmetadata></topicpartition>：
- 例如只提交
user-topic的 offset：Map<topicpartition offsetandmetadata> offsets = new HashMap(); for (TopicPartition tp : records.partitions()) { if ("user-topic".equals(tp.topic())) { offsets.put(tp, new OffsetAndMetadata(records.offsetsForPartitions(Collections.singleton(tp)).get(tp).offset() + 1)); } } consumer.commitSync(offsets);</topicpartition> - 自动提交（
enable.auto.commit=true）则统一按 poll 周期提交全部，无需干预
反序列化与 Schema 兼容性是隐性难点
多 Topic 共用一个 Consumer 实例时，value 反序列化器（如 StringDeserializer）必须能兼容所有 Topic 的消息格式：
- 如果
order-topic发 JSON，log-topic发纯文本，用StringDeserializer没问题；但若混用 Avro/Protobuf，需统一 Schema Registry 或自定义反序列化器 - 推荐在 record 处理前加简单校验：
if (record.value() == null) continue;或尝试 JSON 解析失败时跳过/打日志 - 避免因某 Topic 消息格式异常导致整个 poll 批次中断
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
