You need to pass the stream ID (you define it ) in SpoutOutputCollector emit method (first parameter) And you need also to pass stream id when you build a topology (TopologyBuilder) . For example when you call shuffleGrouping method Vladi
On Mon, Jul 14, 2014 at 11:50 AM, Link Wang <[email protected]> wrote: > Dear all, > > I'm using KafkaSpout of 0.9.2-incubating, I want my KafkaSpout to emit > more than one stream with given streamID, but It seems that there's not way > to do this. any help? > bellow is my pom dependency of storm-kafka: > <dependency> > <groupId>org.apache.storm</groupId> > <artifactId>storm-kafka</artifactId> > <version>0.9.2-incubating</version> > </dependency> > > Link Wang >
