this is my connector config. why not created? is deprecated insertAppIdHeader? do you have any solution?
{
"connector.class": "MongoDbAtlasSink",
"name": "confluent-mongodb-sink",
"kafka.auth.mode": "KAFKA_API_KEY",
"kafka.api.key": "",
"kafka.api.secret": "",
"input.data.format" : "AVRO",
"connection.host": "",
"connection.user": "",
"connection.password": "",
"topics": "cju.create_order",
"max.num.retries": "3",
"retries.defer.timeout": "5000",
"max.batch.size": "0",
"database": "",
"collection": "",
"tasks.max": "1",
"transforms": "insertAppIdHeader",
"transforms.insertAppIdHeader.type": "org.apache.kafka.connect.transforms.InsertHeader",
"transforms.insertAppIdHeader.header": "uuid",
"transforms.insertAppIdHeader.value.literal": "uuid"
}
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.