Search before asking
Enhancement Request
Since the http source/sink connector uses a queue to achieve asynchronous decoupling, that is, after the source connector receives the request, it puts it into the queue and returns the result. However, it does not know the execution status of the sink side. We need to provide a way to achieve this. The result callback on the sink side is returned to the source side.
Describe the solution you'd like
connectorRecord will have a callback and the sink side will call the onSuccess or onException which are mapped to the commit and onException methods of the source connector respectively.
Are you willing to submit PR?
Code of Conduct
Search before asking
Enhancement Request
Since the http source/sink connector uses a queue to achieve asynchronous decoupling, that is, after the source connector receives the request, it puts it into the queue and returns the result. However, it does not know the execution status of the sink side. We need to provide a way to achieve this. The result callback on the sink side is returned to the source side.
Describe the solution you'd like
connectorRecord will have a callback and the sink side will call the
onSuccessoronExceptionwhich are mapped to the commit and onException methods of the source connector respectively.Are you willing to submit PR?
Code of Conduct