apache kafka - Storm KafkaSpout can't read offset when topic partition more than 1 -


my kafkaspout set

     spoutconfig spoutconf = new spoutconfig(brokerhosts, topic, zkroot,clientid);     spoutconf.scheme = new schemeasmultischeme(new stringscheme());     spoutconf.forcefromstart = false;     spoutconf.zkservers=...     spoutconf.zkport = 2181;     spoutconf.zkhost = ...     spoutconf.zkroot = zkroot;     
failing write offset data zookeeper in kafka-storm, found,when topic partition bigger 1, kafkaspout can't read offset zookeeper , there no settings in zookeeper.


Comments

Popular posts from this blog

angularjs - ADAL JS Angular- WebAPI add a new role claim to the token -

php - CakePHP HttpSockets send array of paramms -

node.js - Using Node without global install -