
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
kafka消费者之多线程方案
在一个消费者组中,每个分区都只能被组内的一个消费者实例所消费。假设一个消费者组订阅了100个分区,那么他只能扩展到100个线程。,如果消息获取速度慢,增加获取消息的线程数;如果消息处理速度慢,增加消息处理的线程。Consumer获取到消息后,处理消息的逻辑是否采用多线程,由开发者决定。Kafka consumer其实是双线程,用户主线程和心跳线程。最大的缺陷是获取消息和处理消息分开了,不是同一个线

到底了







