See: https://github.com/mongodb/mongo-kafka/blob/master/docs/sink.md#use-case-1-employing-business-keys
Looks like it was ported incorrectly: https://github.com/hpgrahsl/kafka-connect-mongodb#use-case-1-employing-business-keys