File tree 1 file changed +33
-0
lines changed
1 file changed +33
-0
lines changed Original file line number Diff line number Diff line change 19
19
ConfigEntry , ResourceType , \
20
20
AlterConfigOpType
21
21
22
+ from tests .common import TestUtils
23
+
22
24
23
25
def assert_expected_config_entries (fs , num_fs , expected ):
24
26
"""
@@ -147,3 +149,34 @@ def test_incremental_alter_configs(kafka_cluster):
147
149
148
150
# Assert expected config entries.
149
151
assert_expected_config_entries (fs , 1 , expected )
152
+
153
+ if TestUtils .use_group_protocol_consumer ():
154
+ group_id = "test-group"
155
+
156
+ res_group = ConfigResource (
157
+ ResourceType .GROUP ,
158
+ group_id ,
159
+ incremental_configs = [
160
+ ConfigEntry ("consumer.session.timeout.ms" , "50000" ,
161
+ incremental_operation = AlterConfigOpType .SET )
162
+ ]
163
+ )
164
+
165
+ expected [res_group ] = ['consumer.session.timeout.ms="50000"' ]
166
+
167
+ #
168
+ # Incrementally alter some configuration values
169
+ #
170
+ fs = admin_client .incremental_alter_configs ([res_group ])
171
+
172
+ assert_operation_succeeded (fs , 1 )
173
+
174
+ time .sleep (1 )
175
+
176
+ #
177
+ # Get current group config
178
+ #
179
+ fs = admin_client .describe_configs ([res_group ])
180
+
181
+ # Assert expected config entries.
182
+ assert_expected_config_entries (fs , 1 , expected )
You can’t perform that action at this time.
0 commit comments