Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[BUG] Exception handling for aws glue schema registry #3264

Closed
hshardeesi opened this issue Aug 26, 2023 · 0 comments · Fixed by #3265
Closed

[BUG] Exception handling for aws glue schema registry #3264

hshardeesi opened this issue Aug 26, 2023 · 0 comments · Fixed by #3265
Labels
bug Something isn't working

Comments

@hshardeesi
Copy link
Contributor

hshardeesi commented Aug 26, 2023

Describe the bug
Kafka source plugin retries every 30s when it hits AWSSchemaRegistryException, which includes both access denied and deserialization errors. As a result, deserialization errors are also retried instead of skipping the records that failed to get deserialized.

Expected behavior

  • Kafka source plugin should retry only if the rootCause of AWSSchemaRegistryException is AccessDenied.
  • In all other cases, records that failed to get deserialized should be skipped (dlq in future) to avoid blocking stream processing.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
Archived in project
Development

Successfully merging a pull request may close this issue.

2 participants