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

KREST-8943 Add an integration test with multiple consumers in parallel. #1114

Merged
merged 2 commits into from Feb 16, 2023

Conversation

msn-tldr
Copy link
Member

This test will setup 2 consumers, each subscribed to the same topic, and that do multiple consumes(GET on /records/) in parallel.

@msn-tldr msn-tldr requested a review from a team as a code owner January 26, 2023 18:35
Copy link
Member

@philipnee philipnee left a comment

Choose a reason for hiding this comment

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

Thanks! Left some comments.

@msn-tldr msn-tldr force-pushed the add_two_consumer_test branch 2 times, most recently from 10dfec9 to f17ed32 Compare January 27, 2023 10:53
@philipnee
Copy link
Member

[io.confluent.kafkarest.ratelimit.FixedCostRateLimitFeatureTest.rateLimitGenericWithMethodCost](https://jenkins.confluent.io/job/Confluent%20Public%20Repo%20PR%20builder/job/kafka-rest/job/PR-1114/4/testReport/io.confluent.kafkarest.ratelimit/FixedCostRateLimitFeatureTest/rateLimitGenericWithMethodCost/)

seems to be failing. Has this been failing consistently?

Copy link
Member

@philipnee philipnee left a comment

Choose a reason for hiding this comment

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

They @msn-tldr - there's a failing test, has it been failing consistently?

This test will setup 2 consumers, each subscribed to the same topic, and
that do multiple consumes(GET  on /records/) in parallel.
Copy link
Contributor

@TemirAskhat TemirAskhat left a comment

Choose a reason for hiding this comment

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

LGTM

1,
consumer1Done,
consumer1ReadyForConsumeLoop,
consumer0ReadyForConsumeLoop /* otherConsumerReadyForConsumeLoop */));
Copy link
Contributor

Choose a reason for hiding this comment

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

[nit] Do we really need those comments?

Versions.KAFKA_V2_JSON_JSON,
Versions.KAFKA_V2_JSON_JSON,
jsonConsumerRecordType,
/* converter= */ null,
Copy link
Contributor

Choose a reason for hiding this comment

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

[nit] Same as below :)

@msn-tldr msn-tldr merged commit e994aab into master Feb 16, 2023
@msn-tldr msn-tldr deleted the add_two_consumer_test branch February 16, 2023 18:06
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.

None yet

3 participants