How to set up a test Kafka consumer so that it does not conflict with the production one and there is no message race?