Hi,
I have a question that I have not resolved via the documentation, looking in 
the "Parallel Execution", "Streaming"  and the "Connectors" sections. If I 
retrieve a kafka stream and then call the process function against it in 
parallel, as follows, does it consume in some round robin fashion between the 
two process calls or is each element coming out of the kafka connector consumed 
by both processors in parallel?
DataStream<SomeObject> inputStream = ... got a kafka streaminputStream.process( 
Function1 );inputStream.process( Function2 );
If it possible to consume in parallel by pointing at the single stream, is it 
typically slower or faster than having two kafka streams with different group 
ids?
If not documented elsewhere, this would be good to cover since it is 
fundamental.

Thanks,
Jason

Reply via email to