Como evitar o reprocessamento da mesma mensagem Kafka? Onde e como organizar a verificação de idempotência no lado do consumidor?