众所周知，kafka为了保证消息消费顺序topic的每个分区只能被消费者组中一个实例消费。
在广灵等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供网站设计制作、成都网站建设 网站设计制作按需网站制作,公司网站建设,企业网站建设,成都品牌网站建设,成都营销网站建设,外贸营销网站建设,广灵网站建设费用合理。
如果你的topic分区数为36，则可以尝试调整消费者实例数为36，当然这个是消费者ConsumerFactory.concurrency = 1的情况。如果你调整了线程数为n，则你的消费者实例数最优为Math.ceil(36/n)。
可以把ConcurrentKafkaListenerContainerFactory.setBatchListener(true)开启批量消费，并配置批量消费数ConsumerFactory.MAX_POLL_RECORDS_CONFIG = 100，默认为500
消费者使用线程池进行批量消费数据。建议不要使用execute，否则容易失控，建议使用submit然后得到future.get，get的时候会等待线程执行完，这种方式会把本次批量消费完再往下消费。
此时线程池的核心线程数就需要根据业务是IO密集型还是CPU密集型来决定，如果是IO密集型线程数可以多设置些，如果是CPU密集型线程数可以根据核心数来决定。
售后响应及时
7×24小时客服热线
数据备份
更安全、更高效、更稳定
价格公道精准
项目经理精准报价不弄虚作假
合作无风险
重合同讲信誉，无效全额退款
网站设计包含服务
网站制作流程
有效沟通方式
售后服务
+ 品牌创意
+ 宣传视频
+ 大陆官网
+ 外贸官网
+ 移动应用
+ 形象设计
网站建设
网站优化
网站制作
网站制作
网络营销
网站维护
公司简介
我们的观点
为什么选择我们
企业文化
支付方式
联系方式
在线留言
提交意向表
在线客服
来访路线
