an0r0c / kafka-connect-transform-tojsonstring

transform-to-json-string is a Single Message Transformation (SMT) for Apache Kafka® Connect to convert a given Connect Record to a single JSON String. It's an UNOFFICIAL community project.
Apache License 2.0
32 stars 12 forks source link

why do early return when record doesn't have schema (schemaless record)? #17

Closed jx2lee closed 8 months ago

jx2lee commented 9 months ago

in this line, do early return when key/value schema is null.

Is there a unusal reason set it to ignore if the sink record doesn't have the schema? Unless there's a specific reason, i want to create a PR to apply without schema.

thanks.