kafka-connect-transform-xml
kafka-connect-transform-xml copied to clipboard
Enable DLQing through rerouting for source connectors
This PR also handles updating the README and intros testing for the new functionality.
For source connectors, this can successfully handle the failure and gives it a simple schema. For sinks, it would at least affect the metadata for downstream processing to know this was not successfully processed. If sinks DLQ is enabled the topic would be overwritten again by the framework anyways.
The bad record schema is debatable on whether it's the best implementation, but i think it's simple enough.
This solves #34
getting error like java.lang.NoSuchFieldError: REFLECTION. similar to https://github.com/XeroAPI/Xero-Java/issues/163