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
Make ZK client timeouts configurable #1380
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the contribution!
We also like to provide builder pattern methods for properties like this:
public EmbeddedKafkaBroker zkClientTimeouts(...) {...}
We should also add these properties to @EmbeddedKafkaBroker
with corresponding changes in the EmbeddedKafkaContextCustomizer
and the EmbeddedKafkaCondition
to set the properties in the broker.
Let me know if you want to do this extra work or whether we should take it from here.
Thanks again; looking forward to more.
Hi @garyrussell , sure, happy to take this forward. Didn't you mean |
Sorry. Yes @embeddedkafka. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please, add your name to the @author
list, update copyright to the current year and @since
to all the new API in all the affected class.
spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/CC @garyrussell
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM; thanks!
* Make ZK client timeouts configurable * Wire ZK clients timeouts to @embeddedkafka properties * Splitting the ZK client timeout properties, @author * @SInCE on new API
And cherry-picked as abf2bfe to 2.3.x with deprecated Thanks again @pawellozinski |
👍 |
For build servers with high load, it may happen that the build hangs for couple of seconds. This causes the internal ZK client session of embedded Kafka broker to timeout and fail the build.
It would be good if these were configurable.