kafka-connect-transform-xml icon indicating copy to clipboard operation
kafka-connect-transform-xml copied to clipboard

Enable DLQing through rerouting for source connectors

Open abraham-leal opened this issue 4 years ago • 1 comments

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

abraham-leal avatar Sep 29 '20 15:09 abraham-leal

getting error like java.lang.NoSuchFieldError: REFLECTION. similar to https://github.com/XeroAPI/Xero-Java/issues/163

tooptoop4 avatar Dec 16 '22 09:12 tooptoop4