Skip to content

Conversation

sobychacko
Copy link
Contributor

@sobychacko sobychacko commented Feb 13, 2024

  • Clarify how KafkaStreamsInteractiveQueryService retries work in the docs

* Clarify how KafkaStreamsInteractiveQueryService retries works in the docs

When trying to retrieve the state store using the `KafkaStreamsInteractiveQueryService`, there is a chance that the state store might not be found for various reasons.
If those reasons are transitory, `KafkaStreamsInteractiveQueryService` provides an option to retry the retrieval of the state store by allowing to inject a custom `RetryTemplate`.
By default, the `RetryTemmplate` that is used in `KafkaStreamsInteractiveQueryService` does not attempt any retries if the first attempt to retrieve the state store fails.
Copy link
Member

Choose a reason for hiding this comment

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

does not attempt any retries

That's not correct. See RetryTemplate.retryPolicy by default:

private volatile RetryPolicy retryPolicy = new SimpleRetryPolicy(3);

Or do you just talk about something else, like you are mentioning above about back-off?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Got it. I want to reset that default to a single try by default, which I will do via another PR. For now, I synched the docs with the current state of the code.

@artembilan artembilan added this to the 3.2.0-M1 milestone Feb 13, 2024
@artembilan artembilan merged commit e7e77b9 into spring-projects:main Feb 13, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants