Настройка
Таблица клиентов с полем CustomerID как nvarchar (50).(допустим, CustomerID = 100)
Слитный соединитель JDBC Soruce
SMT (ValueToKey, ExtractField)
Требование -
требуется, чтобы в качестве ключа для customerIDЗапись Кафки
Пожалуйста, найдите ниже конфигурации.
transforms=createKey,extractStr
transforms.createKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.createKey.fields=CustomerID
transforms.extractStr.type=org.apache.kafka.connect.transforms.ExtractField$Key
transforms.extractStr.field=CustomerID
Получение ниже вывода
"100" {"CustomerID": "100", "CustomerName": "Deepak"," City ":" Chandigarh "}
Ожидаем ключ как 100, но получаем как" 100 ".Добавлены дополнительные двойные кавычки.
Посоветуйте, пожалуйста, как это исправить.