Fix kafkastreamer consumer group race conditions and backpressure handling#175

Copilot wants to merge 5 commits intomainluno/workflow:mainfrom

copilot/review-kafkastreamer-adapterluno/workflow:copilot/review-kafkastreamer-adapterCopy head branch name to clipboard