kafka topic offsets of 3 partitions has no banlance on DC/OS -
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
Post a Comment