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

KAFKA-9295: increase heartbeat and session timeout #10715

Merged
merged 2 commits into from May 19, 2021

Conversation

showuon
Copy link
Contributor

@showuon showuon commented May 18, 2021

increase heartbeat and session timeout to make the test reliable.
session timeout -> 20 sec
heartbeat timeout -> 20/3 = 7 sec

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@showuon
Copy link
Contributor Author

showuon commented May 18, 2021

@ableegoldman , as discussed, could you help review this PR to increase session timeout? Thanks.

@showuon
Copy link
Contributor Author

showuon commented May 18, 2021

failed test is flaky RaftClusterTest:

Build / JDK 15 and Scala 2.13 / kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic()

@ableegoldman
Copy link
Contributor

@showuon I don't think we need to increase the heartbeat interval, let's just bump up the session timeout for now. We still want to be relatively quick in our broker requests/responses

@showuon
Copy link
Contributor Author

showuon commented May 19, 2021

@ableegoldman , no problem! Updated! Thanks.

Copy link
Contributor

@ableegoldman ableegoldman left a comment

Choose a reason for hiding this comment

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

LGTM, hopefully the tests pass 🤞

@showuon
Copy link
Contributor Author

showuon commented May 19, 2021

I'll monitor it and let you know when completed. :)

@showuon
Copy link
Contributor Author

showuon commented May 19, 2021

@ableegoldman , Failed test is unrelated and flaky. Thanks.

Build / JDK 15 and Scala 2.13 / kafka.server.RaftClusterTest.testCreateClusterAndCreateAndManyTopics()

@ableegoldman ableegoldman merged commit e11f249 into apache:trunk May 19, 2021
@ableegoldman
Copy link
Contributor

Merged to trunk at exactly 11pm PST (May 18th 2021) -- be on the lookout for any failures on builds kicked off after this time

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
2 participants