www.ntzj.net > kAFkAspout oFFsEt

kAFkAspout oFFsEt

已经消费了数据,但是offset没提交。 原因1:强行kill线程,导致消费后的数据,offset没有提交。

public PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id) { _partition = id; _connections = connections; _spoutConfig = spou...

网站地图

All rights reserved Powered by www.ntzj.net

copyright ©right 2010-2021。
www.ntzj.net内容来自网络,如有侵犯请联系客服。zhit325@qq.com