Im creating a sink connector for mongodb using msk connect. The data I'm publishing to kafka topic is protof encoded.
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
key.converter.schemas.enable=false
database=MongoDBMSKDemo
tasks.max=1
topics=MongoDBMSKDemo.Source
connection.uri= <mongodb connection url>
value.converter.schemas.enable=true
collection=Sink
value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
max.batch.size=10
key.converter=org.apache.kafka.connect.storage.StringConverter
But the data not getting stored in mongodb getting below error.
org.apache.kafka.connect.errors.DataException: Could not convert value `[B@51798b7f` into a BsonDocument.
Can anyone please tell me how to get through this?