Kafka消费者配置需关注以下核心要点，确保消息可靠消费与系统稳定性：
一、基础配置必填项
- bootstrap.servers：指定Kafka集群地址，建议配置多个broker地址以实现高可用。
- group.id：消费者组唯一标识，同一组内消费者共同消费分区，不同组可并行消费。
- key/value deserializer：指定消息键值的反序列化器，如
StringDeserializer。
二、偏移量管理关键配置
- enable.auto.commit：生产环境建议设为
false，避免自动提交导致消息丢失，改为手动提交consumer.commit()。
- auto.offset.reset：设为
earliest（从最早消息开始）或latest（从最新消息开始），none需确保有已提交偏移量。
三、性能优化配置
- max.poll.records：控制单次
poll()返回的最大消息数，避免单次处理任务过重，建议根据消息处理耗时调整。
- fetch.min.bytes/fetch.max.wait.ms：合理设置可减少网络往返，如
fetch.min.bytes=1024、fetch.max.wait.ms=500。
四、消费者组与心跳配置
- session.timeout.ms：消费者会话超时时间，需大于
heartbeat.interval.ms的2倍，避免被误判为离线。
- heartbeat.interval.ms：心跳发送间隔，建议设置为
session.timeout.ms的1/3。
- max.poll.interval.ms：两次
poll()的最大间隔，处理耗时任务时需增大该值，避免触发rebalance。
五、安全与高级配置
- security.protocol：启用SSL/TLS或SASL加密，如
SASL_SSL。
- isolation.level：设为
read_committed可避免消费未提交的事务消息。
六、最佳实践建议
- 手动提交偏移量：重要业务场景手动控制提交时机，确保消息处理完成后再提交。
- 监控与告警：关注消费者滞后量（lag）、rebalance次数等指标，及时处理异常。
- 资源隔离：多实例部署时合理分配分区，避免单个消费者负载过高。