When some unknown type is used in the record schema, the sink connector simply rejects the record by saying:
Caused by: com.sap.kafka.utils.ConnectorException: Field Schema type name xxxxxxxxxxx is invalid
It would be more practical and convenient to interpret the type using its base type mapping so that the data can be inserted to the target HANA table.
When some unknown type is used in the record schema, the sink connector simply rejects the record by saying:
Caused by: com.sap.kafka.utils.ConnectorException: Field Schema type name xxxxxxxxxxx is invalid
It would be more practical and convenient to interpret the type using its base type mapping so that the data can be inserted to the target HANA table.
This resolves https://github.com/SAP/kafka-connect-sap/issues/115