java - Kafka Storm Integration -

-

i trying integrate kafka , storm.

i have created spout read kafka messages , emit them them tuples.

while running storm topology, getting below exception

caused by: java.io.notserializableexception: kafka.javaapi.consumer.zookeeperconsumerconnector     @ java.io.objectoutputstream.writeobject0(objectoutputstream.java:1184) ~[?:1.8.0_45]     @ java.io.objectoutputstream.defaultwritefields(objectoutputstream.java:1548) ~[?:1.8.0_45]     @ java.io.objectoutputstream.writeserialdata(objectoutputstream.java:1509) ~[?:1.8.0_45]     @ java.io.objectoutputstream.writeordinaryobject(objectoutputstream.java:1432) ~[?:1.8.0_45]     @ java.io.objectoutputstream.writeobject0(objectoutputstream.java:1178) ~[?:1.8.0_45]     @ java.io.objectoutputstream.writeobject(objectoutputstream.java:348) ~[?:1.8.0_45]     @ backtype.storm.utils.utils.javaserialize(utils.java:87) ~[storm-core-0.10.0.jar:0.10.0]     ... 2 more

you should declare non-serializable fields in spout transient. these fields should initialized in open method of spout.


Comments

Post a Comment

Popular posts from this blog

Hatching array of circles in AutoCAD using c# -

-
i beginner in autocad plugins .i have created array of circle using following code. now, have hatch circles in array .how that??how hatch circles @ once? moreover, how can return hatch method , use hatch objects.sorry language.thanks in advance. [assembly: commandclass(typeof(beamsection.class1))] namespace beamsection { public class class1 { //class1 obj = new class1(); [commandmethod("beamatsupport")] public void addlightweightpolyline() { // current document , database document acdoc = application.documentmanager.mdiactivedocument; database accurdb = acdoc.database; promptpointresult ppr = acdoc.editor.getpoint("\nselect starting point "); var ucs = acdoc.editor.currentusercoordinatesystem; point3d startingpt = ppr.value.transformby(ucs); list<double> radius = new list<double>(); radius.add(0.5); ...
Read more

ios - UITEXTFIELD InputView Uipicker not working in swift -

-
hello trying pop uipickerview view programmatically when user clicks on textfield. have tried doesn't doing anything. isn't working. nothing happening when click textfield class userprofiletableviewcontroller: uitableviewcontroller,uitextfielddelegate,uipickerviewdelegate,uipickerviewdatasource { var itempicker: uipickerview! = uipickerview() @iboutlet weak var gendertxtfield: uitextfield! var gender = ["male","female"] override func viewdidload() { super.viewdidload() gendertxtfield.delegate = self itempicker!.delegate = self itempicker!.datasource = self itempicker!.backgroundcolor = uicolor.blackcolor() self.gendertxtfield.inputview = itempicker } func numberofcomponentsinpickerview(pickerview: uipickerview) -> int{ return 1 } // returns # of rows in each component.. func pickerview(pickerview: uipickerview, numberofrowsincomponent component:...
Read more