Как настроить тестовый Kafka-консюмер, чтобы он не конфликтовал с продовым и не было гонки за сообщением?