Broadway pipeline that processes messages from Kafka clusters and persists the received messages if they are not duplicating a previous message.