赞
踩
kafka消息未消费问题
生产环境出现一个业务场景,一个任务执行完后会去更新数据库中最后执行时间这个字段,当时生产环境系统建三个任务同时跑,每次执行成功后只有一个任务的最后执行时间被更新,其他两个没有更新。这个更新操作是放到kafka进行消费,每次只有一个消费成功,另外两个均没有消费,消息也正常生产。经过排查也没发现消息堆积,消费不过来的情况。最后通过查阅资料了解到,**kafka的partition数要比消费者要多,否者可能导致一些线程消费不到消息。**当时生产环境有300个消费数,只有三个分区,所以出现了这个消费不到的问题,经过调整分区数后最后该问题被解决了。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。