Mongo Sink Connector failed to start with error "With the configured document ID strategy, all records are required to have keys, which must be either maps or structs."

Kafka Connect Managed Connectors
1

image
image1685×714 64.7 KB

Mongo Sink Connector failed to start with below error:
“With the configured document ID strategy, all records are required to have keys, which must be either maps or structs.”

Configuration:
|Write Model Strategy|DefaultWriteModelStrategy|
|Max batch size|0|
|Use ordered bulk writes|true|
|Rate limiting timeout|0|
|Rate limiting batch number|0|
|Document ID strategy|FullKeyStrategy|
|Document ID strategy overwrite existing|true|

Actually, the table does not have a primary key, therefore I used ksql “partition by” to construct a key for the record, but it is displayed in string format rather than map or struct. How to create record key in map or struct format using ksql?

Attached error, record key format, configuration.

Thank you so much in advance!!!