公司有网站域名后如何建网站武汉搜索推广

针对某个TOPIC只有几个分区积压的场景，可以采用以下方法进行排查：

1. 消息生产是否指定key？

   如果指定了消息key，那么消息会指定生产到hash(key)的分区中。如果指定了key，那么有下列几种可能：

   • 生产该key的消息体内容与消息处理逻辑是否有与其他分区不同
   • 该key处理逻辑代码中是否有处理异常，导致偏移量无法正常提交
   • 该key消息量大小比其他分区多：不指定消息key，使Kafka分区之间的数据均匀分布

2. 如果不指定key的场景：

   • 订阅该TOPIC的消费组中消费者有多少个？每个消费组负责多少个分区？如果消费者个数过少，比如说有50个分区，但只有3个消费者，那么一个消费者平均要消费16个分区。这种情况可以尝试增加消费者个数，如果使用的是spring-kafka，可以尝试增加concurrency=4/8
   • 是否有消费者频繁Rebalance情况发生，导致偏移量无法提交？如果有，可以参考https://blog.csdn.net/weixin_43180484/article/details/131031640?spm=1001.2014.3001.5502进行排查
   • 吞吐量不够，消费速度赶不上
     • 尝试增加fetch.min.bytes参数（建议调整值1~100000）
     • 增加消费者个数
     • 生产端增加消息压缩:compress.type=lz4