¿Cómo evitar volver a procesar el mismo mensaje de Kafka? ¿Dónde y cómo organizar la verificación de idempotencia en el lado del consumidor?