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