Class MongoDbChangeStreamMessageProducer