Kako sprečiti ponovno procesiranje iste Kafka poruke? Gde i kako organizovati proveru idempotentnosti na strani potrošača?