Skip to content

KAFKA-6944: Add system tests testing the new throttling behavior using older clients/brokers#5294

Closed
jonlee2 wants to merge 2 commits intoapache:trunkfrom
jonlee2:kafka-6944
Closed

KAFKA-6944: Add system tests testing the new throttling behavior using older clients/brokers#5294
jonlee2 wants to merge 2 commits intoapache:trunkfrom
jonlee2:kafka-6944

Conversation

@jonlee2
Copy link
Copy Markdown
Contributor

@jonlee2 jonlee2 commented Jun 26, 2018

Added two additional test cases to quota_test.py, which run between brokers and clients with different throttling behaviors. More specifically,

  1. clients with new throttling behavior (i.e., post-KIP-219) and brokers with old throttling behavior (i.e., pre-KIP-219)
  2. clients with old throttling behavior and brokers with new throttling behavior

Committer Checklist (excluded from commit message)

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

@jonlee2
Copy link
Copy Markdown
Contributor Author

jonlee2 commented Jun 26, 2018

@lindong28 Can you review? Thank you.

@lindong28 lindong28 self-assigned this Jun 26, 2018
@lindong28 lindong28 changed the title KAFKA-6944: Add system tests testing the new throttling behavior usin… KAFKA-6944: Add system tests testing the new throttling behavior using older clients/brokers Jun 26, 2018
Copy link
Copy Markdown
Member

@lindong28 lindong28 left a comment

Choose a reason for hiding this comment

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

Thanks for the patch. Looks good overall.

@matrix(quota_type=[QuotaConfig.CLIENT_ID, QuotaConfig.USER, QuotaConfig.USER_CLIENT], override_quota=[True, False])
@parametrize(quota_type=QuotaConfig.CLIENT_ID, consumer_num=2)
def test_quota(self, quota_type, override_quota=True, producer_num=1, consumer_num=1):
@parametrize(quota_type=QuotaConfig.CLIENT_ID, old_throttling_for_broker=True)
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

Can you replace old_throttling_for_broker with old_broker_throttling_behavior? Same for old_throttling_for_client.

Fix parameter
@lindong28
Copy link
Copy Markdown
Member

Thanks for the patch. Merged to trunk.

@lindong28 lindong28 closed this in a3db23c Jun 27, 2018
ying-zheng pushed a commit to ying-zheng/kafka that referenced this pull request Jul 6, 2018
…g older clients/brokers

Added two additional test cases to quota_test.py, which run between brokers and clients with different throttling behaviors. More specifically,
1. clients with new throttling behavior (i.e., post-KIP-219) and brokers with old throttling behavior (i.e., pre-KIP-219)
2. clients with old throttling behavior and brokers with new throttling behavior

Author: Jon Lee <jonlee@linkedin.com>
Author: Dong Lin <lindong28@gmail.com>

Reviewers: Dong Lin <lindong28@gmail.com>

Closes apache#5294 from jonlee2/kafka-6944
lindong28 pushed a commit that referenced this pull request Jul 21, 2018
…g older clients/brokers

Added two additional test cases to quota_test.py, which run between brokers and clients with different throttling behaviors. More specifically,
1. clients with new throttling behavior (i.e., post-KIP-219) and brokers with old throttling behavior (i.e., pre-KIP-219)
2. clients with old throttling behavior and brokers with new throttling behavior

Author: Jon Lee <jonlee@linkedin.com>
Author: Dong Lin <lindong28@gmail.com>

Reviewers: Dong Lin <lindong28@gmail.com>

Closes #5294 from jonlee2/kafka-6944
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.

2 participants