首页
编程
java
php
前端
首页
编程
java
php
前端
kafak消息阻塞无法入库?
如图消费kafka里面的数据,但是发现只有在项目刚启动的前几分钟,listen有从kafka里面获取到数据,之后就不消费kafka里面的数据了。可是kafka里面的数据一直都在增加,且堆积了很多,为什么突然就不消费了呢。 排除了网络问题
方法参数里面有ack,是不是配置的手动提交offset,但是忘了提交导致的
kafka 的offset 是手动提交还是自动提交?
点击展开全文