在 Apache Kafka 中，消费者进程通过哪些具体步骤实现对指定主题的订阅，并且 Kafka 支持哪几种消费模式，这些模式在消息分发和消费进度管理上有何区别？
考察说明
考查对 Kafka 消费者订阅机制与消费模式的理解，以及不同模式的应用场景。
回答思路
- 【回答框架 1】订阅机制方面：Kafka 消费者通过 KafkaConsumer 的 subscribe 方法传入主题集合完成订阅，亦可使用 assign 方法直接指定分区。subscribe 支持正则表达式，自动处理分区再均衡；assign 则手动分配分区，不参与再均衡。
- 【回答框架 2】消费模式方面：主要分为订阅模式（subscribe 配合 group.id，实现消费者组内负载均衡和故障转移）和分配模式（assign 手动指定分区，不依赖组管理）。此外，Kafka 还支持独立消费者（无 group.id，或使用 assign）和消费者组模式。
- 【回答框架 3】区别方面：订阅模式依赖组协调器，分区自动分配，消费进度（offset）由 Kafka 管理，支持再均衡；分配模式需自行管理 offset 和分区分配，灵活但缺少容错。消费者组模式允许横向扩展，同一分区只被组内一个消费者消费，实现顺序保证。
- 【回答框架 4】实际应用中，通常使用 subscribe 加消费者组处理高吞吐场景，assign 适合有状态或有特殊分区需求的场景，如精确控制分区消费顺序。
- 【关键点 1】subscribe 订阅主题并自动处理分区再均衡；assign 手动指定分区，无自动再均衡。
- 【关键点 2】消费者组通过组协调器实现负载均衡，同一分区仅由组内一个消费者消费。
- 【关键点 3】消费模式包括订阅模式、分配模式和独立消费者模式，核心区别在分区分配与 offset 管理方式。
- 【易错点 1】混淆 subscribe 与 assign，两者混用会触发 IllegalArgumentException。
- 【易错点 2】认为消费者组保证所有消息只消费一次，实际需配合幂等和事务才能实现精确一次语义。
- 【易错点 3】忽略再均衡可能导致消费中断和重复消费，需实现再均衡监听器处理。