kafka topic offsets of 3 partitions has no banlance on DC/OS -


3 partition,2 of them 600+,partition 1 585

my kafkaspout run out of range because of partition 1. conf below:

spoutconfig spoutconfig = new spoutconfig(zkhosts, topic, zkroot, zkspoutid); spoutconfig.startoffsettime = kafka.api.offsetrequest.latesttime(); 

and spoutconfig.usestartoffsettimeifoffsetoutofrange = true default.


Comments

Popular posts from this blog

Command prompt result in label. Python 2.7 -

javascript - How do I use URL parameters to change link href on page? -

amazon web services - AWS Route53 Trying To Get Site To Resolve To www -