Jak zapobiec ponownemu przetwarzaniu tej samej wiadomości Kafka? Gdzie i jak zorganizować sprawdzanie idempotencji po stronie konsumenta?