首页
个人开发
工作相关
共享
搜索
登录
搜索
colo
欲买桂花同载酒
累计撰写
1823
篇文章
累计收到
0
条评论
首页
栏目
首页
个人开发
工作相关
共享
Kafka
2025-12-6
如何保证Kafka消费者在故障场景下不丢失消息且不重复处理？
核心解决方案要点：启用自动偏移提交：设置enable.auto.commit=false手动控制提交幂等处理：业务逻辑需支持重复数据过滤事务性消费：使用Kafka事务API将消费与处理绑定原子操作隔离级别：配置isolation.level=read_committed避免读取未提交消息检查点机制：在处理完成后同步保存偏移量与业务状态
2025年-12月-6日
8 阅读
0 评论
Kafka
2025-12-6
如何避免Kafka消费者组频繁重平衡？请分析原因并提出解决方案
避免频繁重平衡的核心要点：合理配置会话超时：适当增大 session.timeout.ms（默认10秒）调整心跳间隔：设置 heartbeat.interval.ms 为 session.timeout.ms 的1/3优化处理逻辑：避免单条消息处理时间超过 max.poll.interval.ms正确关闭消费者：调用 consumer.close() 主动注销监控消费延迟：跟踪 current-offset 和 log-end-offset 差值
2025年-12月-6日
5 阅读
0 评论
Kafka
2025-12-6
如何避免 Kafka 消费者组频繁重平衡？
避免 Kafka 消费者组频繁重平衡的核心要点：合理配置超时参数：调整 session.timeout.ms、heartbeat.interval.ms 和 max.poll.interval.ms确保及时心跳：避免消费者处理消息时间过长阻塞心跳线程使用静态成员资格：通过 group.instance.id 减少临时离线导致的再平衡优雅关闭消费者：调用 consumer.close() 主动通知协调器监控与告警：跟踪重平衡次数和原因（如 kafka-consumer-groups 工具）
2025年-12月-6日
5 阅读
0 评论
Kafka
1
2
