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

Tests: change assertions to fix #832 #892

Merged
merged 3 commits into from Oct 2, 2019

Conversation

ennru
Copy link
Member

@ennru ennru commented Sep 4, 2019

Not all messages are received, possibly because this runs so slow on Travis.

@ennru
Copy link
Member Author

ennru commented Sep 5, 2019

There is more to this problem.

@ennru
Copy link
Member Author

ennru commented Oct 1, 2019

The failing assertions try to validate that all messages produced in the test are received by the consumers. This has shown to be extremely flaky on Travis so I changed the test to not assert it anymore.

@ennru ennru changed the title Tests: wait longer to see if it fixes #832 Tests: change assertions to fix #832 Oct 1, 2019
@ennru ennru requested a review from seglo October 1, 2019 08:23
Copy link
Member

@seglo seglo left a comment

Choose a reason for hiding this comment

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

LGTM. Left a question about how this test works.

@@ -114,17 +114,26 @@ class IntegrationSpec extends SpecBase with TestcontainersKafkaLike with Inside
rebalanceActor2.expectMsg(TopicPartitionsRevoked(subscription2, Set.empty))
rebalanceActor2.expectMsg(TopicPartitionsAssigned(subscription2, Set(allTps(2), allTps(3))))

sleep(2.seconds,
sleep(4.seconds,
"to get the second consumer started, otherwise it might miss the first messages because of `latest` offset")
Copy link
Member

Choose a reason for hiding this comment

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

Unrelated to this PR, but why can't we use a test probe on the second consumer actor to assert when to proceed instead of waiting?

@seglo seglo merged commit 752c58b into akka:master Oct 2, 2019
@ennru ennru deleted the change-rebalance-signal-wait branch October 3, 2019 06:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants