Reset Kafka consumer offset when a message is not fully handled by the deduplicator

• Investigate how the consumer offset of the deduplicator is updated in case of an exception/interruption and make sure the deduplication is fault tolerant