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

fixes #147: Kafka Connect Sink Transient Error Mangement #148

Merged
merged 1 commit into from
Feb 12, 2019

Conversation

conker84
Copy link
Contributor

Fixes #147

Proposed Changes (Mandatory)

A brief list of proposed changes in order to fix the issue:

  • added a coroutine scoped function retryForException which retries for a set of exceptions
  • added property neo4j.retry.backoff.msecs used by the Neo4j java driver withMaxTransactionRetryTime
  • added property neo4j.retry.max.attemps used by retryForException in Neo4jService
    in order to retry the operation for transient errors

@conker84
Copy link
Contributor Author

conker84 commented Feb 1, 2019

@jexp updated!

@jexp
Copy link
Member

jexp commented Feb 12, 2019

Looks good, thanks a lot.

@jexp jexp merged commit a7fa882 into neo4j-contrib:master Feb 12, 2019
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.

Kafka Connect Sink Transient Error Mangement
2 participants