Connector used by Horizon for transferring and transforming data from Kafka to MongoDB - View it on GitHub