Разкажете повече за работата с Kafka: как точно се извършваше дедупликацията на съобщенията?