Como configurar um consumidor de Kafka de teste para que não entre em conflito com o de produção e não haja corrida pela mensagem?