Closed aliostad closed 7 years ago
Hi,
As raised before, current implementation is not thread-safe since data gets received by the processor for all partitions. This small fix allows that one processor gets created for each partition.
It was impossible to add unit test.
Cheers Ali
looks good. ack on untestable which is a known issue with the library sadly
appreciated!
Thanks!
Hi,
As raised before, current implementation is not thread-safe since data gets received by the processor for all partitions. This small fix allows that one processor gets created for each partition.
It was impossible to add unit test.
Cheers Ali