-
Notifications
You must be signed in to change notification settings - Fork 912
KIP 848:Extend DescribeConfigs and IncrementalAlterConfigs to support GROUP Config #1856
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
Conversation
🎉 All Contributor License Agreements have been signed. Ready to merge. |
bd9120d
to
b88b020
Compare
658c698
to
e709ce7
Compare
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.
Add CONFIG_SOURCE_GROUP_CONFIG
to admin/_init.py as well to expose in confluent_kafka.admin
module.
704c33b
to
61ddbe5
Compare
This comment has been minimized.
This comment has been minimized.
1 similar comment
This comment has been minimized.
This comment has been minimized.
ec32ad3
to
ab0ebab
Compare
This comment has been minimized.
This comment has been minimized.
ab0ebab
to
7c1cf51
Compare
This comment has been minimized.
This comment has been minimized.
7c1cf51
to
a9c0566
Compare
This comment has been minimized.
This comment has been minimized.
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!.
@@ -147,3 +149,34 @@ def test_incremental_alter_configs(kafka_cluster): | |||
|
|||
# Assert expected config entries. | |||
assert_expected_config_entries(fs, 1, expected) | |||
|
|||
if TestUtils.use_group_protocol_consumer(): |
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.
if TestUtils.use_group_protocol_consumer(): | |
# TODO: enable this test for the classic run too, when | |
# Confluent Platform test cluster is upgraded to 8.0.0 | |
if TestUtils.use_group_protocol_consumer(): |
This PR intends to add support for Group Resource type for IncrementalAlterConfigs API as specified in KIP 848 and extended the DescribeConfigs support till API version 3.
Additional changed the integration test to check for Group Resource Type.
Librdkafka PR: #4939