Ubuntu Kafka配置中常见问题

在Ubuntu上配置Kafka时，可能会遇到一些常见问题。以下是一些常见问题的解决方案：

消息堆积

• 现象：生产者狂发消息，消费者处理速度慢，导致消息积压，监控告警狂响。
• 原因：消费者代码性能差（如同步阻塞、未批量处理）。分区数不足，无法并行消费。消费者组内成员分配不均。
• 解决方案：
  • 优化消费者代码：改用异步非阻塞处理（如使用线程池）。批量拉取消息（max.poll.records调大）。
  • 增加分区数：./kafka-topics.sh --alter --topic 订单日志 --partitions 6 --bootstrap-server localhost:9092。
  • 调整分配策略：使用RoundRobinAssignor替代默认的RangeAssignor，均衡负载。

数据丢失

• 现象：生产者发送成功，但消费者读不到消息。
• 原因：生产者未开启ACK确认（acks=0或1）。Leader副本宕机，且未同步到Follower。
• 解决方案：
  • 生产者配置：acks=all # 确保所有ISR副本确认后才返回成功。retries=3 # 自动重试。
  • Broker配置：min.insync.replicas=2 # 至少2个副本确认才允许写入。

消费者重复消费

• 现象：消费者重启或崩溃后，重复处理已读消息。
• 原因：消费者提交Offset失败（如崩溃前未提交）。自动提交Offset间隔太长（auto.commit.interval.ms默认5秒）。
• 解决方案：
  • 手动提交Offset：consumer.commitSync(); // 处理完消息后同步提交。
  • 缩短自动提交间隔：auto.commit.interval.ms=1000 // 1秒提交一次。

Leader切换导致短暂不可用

• 现象：Broker宕机后，分区Leader切换期间，生产者发送消息超时。
• 解决方案：
  • 增加重试机制：retries=5，retry.backoff.ms=1000 // 在尝试重试对给定主题分区的失败请求之前等待的时间。
  • 客户端缓存消息：生产者启用本地缓存（如Kafka的buffer.memory），避免消息丢失。

磁盘写满，Broker罢工

• 现象：Broker日志磁盘占用100%，无法写入新消息。
• 解决方案：
  • 紧急清理过期日志：./kafka-delete-records.sh --bootstrap-server localhost:9092 --offset-json-file cleanup.json。
  • 预防配置：log.retention.hours=72 # 缩短保留时间。log.retention.bytes=1073741824 # 每个分区最多保留1GB。

ZooKeeper连接闪断，集群抖动

• 现象：频繁报错“ZooKeeper session expired”，Controller频繁切换。
• 解决方案：
  • 优化ZooKeeper配置：zookeeper.session.timeout.ms=18000 # 增加会话超时时间。
  • 监控ZooKeeper配置：避免ZooKeeper集群压力过大（如分离Kafka和ZooKeeper的物理资源）。

消费者组重平衡太频繁

• 现象：消费者组频繁重新分配分区，导致消费暂停。
• 原因：消费者心跳超时（处理消息时间过长，未及时发送心跳）。网络波动导致Group Coordinator认为消费者下线。
• 解决方案：
  • 紧急清理过期日志：session.timeout.ms=30000 # 心跳超时时间调大。max.poll.interval.ms=300000 # 拉取消息间隔上限调大。
  • 优化消息处理逻辑：避免单条消息处理耗时过长。

跨机房同步延迟高

• 现象：异地多机房部署时，副本同步延迟高，ISR列表不稳定。
• 解决方案：
  • 优先同机房同步：broker.rack=us-east-1a # 标记Broker所在机房。
  • 调整副本拉取参数：replica.socket.timeout.ms=120000 # 增加副本同步超时时间。

希望这些信息能帮助你在配置Kafka时避免一些常见问题。如果问题依然存在，建议查看Kafka的官方文档或寻求社区的帮助。