This change checks for HTTPException on the AEP Publish task, and forces a Connect sink task failure on the put() call.
This behaviour will ensure that we will not move the commit marker forward if the message was not published successfully.
Changes
This PR will fail the sink task on unrecoverable http exceptions.
Note that this will require the connect task to be resumed once the exception has been addressed.
Introduced http response code in the HttpException
Throw the connect exception only for http code 401 or 500
We are consciously not moving the messages into a dead letter queue here since that this not the desired behaviour for this condition.
Relevant Documentation
Please enter the links of any docs updated to reflect this change
How Has This Been Tested?
Create a inlet with auth enabled
Ensured that the auth token was not properly set in the connect config
Validated that the sink task failed.
Types of changes
[X] Bug fix (non-breaking change which fixes an issue)
[ ] New feature (non-breaking change which adds functionality)
[ ] Breaking change (fix or feature that would cause existing functionality to change)
Summary
This change checks for HTTPException on the AEP Publish task, and forces a Connect sink task failure on the put() call. This behaviour will ensure that we will not move the commit marker forward if the message was not published successfully.
Changes
We are consciously not moving the messages into a dead letter queue here since that this not the desired behaviour for this condition.
Relevant Documentation
Please enter the links of any docs updated to reflect this change
How Has This Been Tested?
Types of changes
Checklist