记一次Kafka消费者拉取多个节点的数据,其中有1-2个节点出现拉取流量比较大问题其原洇是
我把consumer拉取的数据的自动提交配置设置成了false,而并没调用commit(offset)提交接口,推送导致是其原因由于没确认又重复的拉取数据了
之后修改成自动確认的问题解决了。
mit 设置为 true需要在每次poll时,确保前一次poll出来的数据已经消费完毕否则可能导致位点跳跃。如果想自己控制位点提交則把 mit 设为 false,并调用commit(offsets)函数自行控制位点提交