Solved.
Looks like mongo sink connector had problem with the message key.
I was sending string key, but even if the key converter is String it requires at least valid json encoded string.
Solution :
transforms=WrapKey
transforms.WrapKey.type=org.apache.kafka.connect.transforms.HoistField$Key
transforms.WrapKey.field=_id
1 Like