Use Parallel.ForEach(...) to forward records in child processor inside one topology about kafka-streams-dotnet HOT 6 CLOSED

@LGouellec, We can address the above mentioned issue with the following code,

Parallel.ForEach(Next.OfType<IProcessor<K1, V1>>(), p => p.Process(key, value));

when we have to filter by name we can make use of linq to perform the same

var processors = Next.OfType<IProcessor<K1, V1>>() .Where(p => p.Name.Equals(name));

from kafka-streams-dotnet.

@LGouellec, Have made the respective changes. Let me know if I can create pull request for the same

from kafka-streams-dotnet.

@vimal-sivasubramanian , Hi ! No I can't made this changes yet. Yes you can create a PR if you have free time :) Thanks

from kafka-streams-dotnet.

Hi @LGouellec, I'm unable to push my feature branch due permission issues, Can you please add me as an contributor :) Thanks

from kafka-streams-dotnet.

Hi @vimal-sivasubramanian, you have just to fork my project, and create a PR on develop branch. Normally it's open.
On the other hand, you can't push directly on my develop branch of course.

from kafka-streams-dotnet.

@LGouellec I oppened a pull request pertaining this issue, let me know what you think!
#153

from kafka-streams-dotnet.