Details
-
Bug
-
Resolution: Works as Designed
-
Major - P3
-
None
-
1.3.0
-
None
Description
When trying to add a heartbeatĀ to the existing working configuration
"heartbeat.interval.ms": 60000, |
"heartbeat.topic.name": "heartbeats-mongodb" |
I'm getting the following error:
Caused by: org.apache.kafka.connect.errors.DataException: Only Struct objects supported for [copying fields from value to key], found: java.lang.String
configuration example:
{
|
"connector.class": "com.mongodb.kafka.connect.MongoSourceConnector", |
"transforms.extractKeyField.type": "org.apache.kafka.connect.transforms.ExtractField$Key", |
"output.format.value": "schema", |
"change.stream.full.document": "updateLookup", |
"transforms": "ValueToKey,extractKeyField", |
"transforms.extractKeyField.field": "documentKey", |
"collection": "test", |
"transforms.ValueToKey.fields": "documentKey", |
"key.converter.schemas.enable": "false", |
"database": "db", |
"topic.prefix": "prefix", |
"connection.uri": "mongodb://localhost", |
"value.converter.schemas.enable": "false", |
"name": "mongodb-source", |
"copy.existing": "true", |
"value.converter": "org.apache.kafka.connect.json.JsonConverter", |
"key.converter": "org.apache.kafka.connect.json.JsonConverter", |
"poll.max.batch.size": "100", |
"transforms.ValueToKey.type": "org.apache.kafka.connect.transforms.ValueToKey" |
}
|