-
Type: Task
-
Resolution: Works as Designed
-
Priority: Major - P3
-
None
-
Affects Version/s: None
-
Component/s: None
-
None
I try to use mongo document id as message key. Following this examples https://docs.confluent.io/current/connect/transforms/valuetokey.html#valuetokey i specify settings in MongoSourceConnector.properties but connector raise exception:
Only Struct objects supported for [copying fields from value to key], found: java.lang.String
- depends on
-
KAFKA-40 Support schema for Source connector
- Development Complete