parallel-consumer
parallel-consumer copied to clipboard
Ensure all PC API's are thread safe
Currently PC is multi threaded but underlying Kafka consumer is not. So a scenario such as
- thread one subscribes to topic one
- thread two subscribes to topic two
will fail since the underlying kafka consumer will reject the second subscribe, due to the consumer's thread safety checks
Relates to: Enable changing of topic subscription before or after PC has started #187
Fixed by:
- #346