Skip to content

Classify all Kafka errors as recoverable bar some exceptions#38

Merged
philipp94831 merged 4 commits intomasterfrom
feature/better-error-filtering
Nov 15, 2019
Merged

Classify all Kafka errors as recoverable bar some exceptions#38
philipp94831 merged 4 commits intomasterfrom
feature/better-error-filtering

Conversation

@philipp94831
Copy link
Copy Markdown
Member

Most Kafka errors are either recoverable or should stop processing. Therefore, they should be forwarded by default by all error handlers.

Furthermore, the clean up only logged errors upon schema registry clean up. This behavior has been changed to a thrown exception.

@philipp94831 philipp94831 self-assigned this Nov 15, 2019
return false;
}
if (e instanceof SerializationException) {
return e.getCause() instanceof SocketTimeoutException;
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Add a comment

@philipp94831 philipp94831 merged commit e254dc0 into master Nov 15, 2019
@philipp94831 philipp94831 deleted the feature/better-error-filtering branch November 15, 2019 13:47
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants