Skip to content

Commit e3df695

Browse files
StephenSorriauxStephenSorriaux
committed
Added AlterConfigs and DescribeConfigs apis
1 parent 6163aa3 commit e3df695

File tree

1 file changed

+192
-1
lines changed

1 file changed

+192
-1
lines changed

‎kafka/protocol/admin.py

Lines changed: 192 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from __future__ import absolute_import
22

33
from kafka.protocol.api import Request, Response
4-
from kafka.protocol.types import Array, Boolean, Bytes, Int16, Int32, Schema, String
4+
from kafka.protocol.types import Array, Boolean, Bytes, Int8, Int16, Int32, Schema, String
55

66

77
class ApiVersionResponse_v0(Response):
@@ -310,6 +310,197 @@ class SaslHandShakeRequest_v1(Request):
310310
SaslHandShakeRequest = [SaslHandShakeRequest_v0, SaslHandShakeRequest_v1]
311311
SaslHandShakeResponse = [SaslHandShakeResponse_v0, SaslHandShakeResponse_v1]
312312

313+
class AlterConfigsResponse_v0(Response):
314+
API_KEY = 33
315+
API_VERSION = 0
316+
SCHEMA = Schema(
317+
('throttle_time_ms', Int32),
318+
('resources', Array(
319+
('error_code', Int16),
320+
('error_message', String('utf-8')),
321+
('resource_type', Int8),
322+
('resource_name', String('utf-8'))))
323+
)
324+
325+
class AlterConfigsRequest_v0(Request):
326+
API_KEY = 33
327+
API_VERSION = 0
328+
RESPONSE_TYPE = AlterConfigsResponse_v0
329+
SCHEMA = Schema(
330+
('resources', Array(
331+
('resource_type', Int8),
332+
('resource_name', String('utf-8')),
333+
('config_entries', Array(
334+
('config_name', String('utf-8')),
335+
('config_value', String('utf-8')))))),
336+
('validate_only', Boolean)
337+
)
338+
339+
AlterConfigsRequest = [AlterConfigsRequest_v0]
340+
AlterConfigsResponse = [AlterConfigsResponse_v0]
341+
342+
343+
class DescribeConfigsResponse_v0(Response):
344+
API_KEY = 32
345+
API_VERSION = 0
346+
SCHEMA = Schema(
347+
('throttle_time_ms', Int32),
348+
('resources', Array(
349+
('error_code', Int16),
350+
('error_message', String('utf-8')),
351+
('resource_type', Int8),
352+
('resource_name', String('utf-8')),
353+
('config_entries', Array(
354+
('config_names', String('utf-8')),
355+
('config_value', String('utf-8')),
356+
('read_only', Boolean),
357+
('is_default', Boolean),
358+
('is_sensitive', Boolean)))))
359+
)
360+
361+
class DescribeConfigsResponse_v1(Response):
362+
API_KEY = 32
363+
API_VERSION = 1
364+
SCHEMA = Schema(
365+
('throttle_time_ms', Int32),
366+
('resources', Array(
367+
('error_code', Int16),
368+
('error_message', String('utf-8')),
369+
('resource_type', Int8),
370+
('resource_name', String('utf-8')),
371+
('config_entries', Array(
372+
('config_names', String('utf-8')),
373+
('config_value', String('utf-8')),
374+
('read_only', Boolean),
375+
('is_default', Boolean),
376+
('is_sensitive', Boolean),
377+
('config_synonyms', Array(
378+
('config_name', String('utf-8')),
379+
('config_value', String('utf-8')),
380+
('config_source', Int8)))))))
381+
)
382+
383+
class DescribeConfigsRequest_v0(Request):
384+
API_KEY = 32
385+
API_VERSION = 0
386+
RESPONSE_TYPE = DescribeConfigsResponse_v0
387+
SCHEMA = Schema(
388+
('resources', Array(
389+
('resource_type', Int8),
390+
('resource_name', String('utf-8')),
391+
('config_names', Array(String('utf-8')))))
392+
)
393+
394+
class DescribeConfigsRequest_v1(Request):
395+
API_KEY = 32
396+
API_VERSION = 1
397+
RESPONSE_TYPE = DescribeConfigsResponse_v1
398+
SCHEMA = Schema(
399+
('resources', Array(
400+
('resource_type', Int8),
401+
('resource_name', String('utf-8')),
402+
('config_names', Array(String('utf-8'))))),
403+
('include_synonyms', Boolean)
404+
)
405+
406+
DescribeConfigsRequest = [DescribeConfigsRequest_v0, DescribeConfigsRequest_v1]
407+
DescribeConfigsResponse = [DescribeConfigsResponse_v0, DescribeConfigsResponse_v1]
408+
409+
class AlterConfigsRequest_v0(Request):
410+
API_KEY = 33
411+
API_VERSION = 0
412+
RESPONSE_TYPE = AlterConfigsResponse_v0
413+
SCHEMA = Schema(
414+
('resources', Array(
415+
('resource_type', Int8),
416+
('resource_name', String('utf-8')),
417+
('config_entries', Array(
418+
('config_name', String('utf-8')),
419+
('config_value', String('utf-8')))))),
420+
('validate_only', Boolean)
421+
)
422+
423+
424+
class AlterConfigsResponse_v0(Response):
425+
API_KEY = 33
426+
API_VERSION = 0
427+
SCHEMA = Schema(
428+
('throttle_time_ms', Int32),
429+
('resources', Array(
430+
('error_code', Int16),
431+
('error_message', String('utf-8')),
432+
('resource_type', Int8),
433+
('resource_name', String('utf-8'))))
434+
)
435+
436+
AlterConfigsRequest = [AlterConfigsRequest_v0]
437+
AlterConfigsResponse = [AlterConfigsResponse_v0]
438+
439+
class DescribeConfigsRequest_v0(Request):
440+
API_KEY = 32
441+
API_VERSION = 0
442+
RESPONSE_TYPE = DescribeConfigsResponse_v0
443+
SCHEMA = Schema(
444+
('resources', Array(
445+
('resource_type', Int8),
446+
('resource_name', String('utf-8')),
447+
('config_names', Array(String('utf-8')))))
448+
)
449+
450+
class DescribeConfigsRequest_v1(Request):
451+
API_KEY = 32
452+
API_VERSION = 1
453+
RESPONSE_TYPE = DescribeConfigsResponse_v1
454+
SCHEMA = Schema(
455+
('resources', Array(
456+
('resource_type', Int8),
457+
('resource_name', String('utf-8')),
458+
('config_names', Array(String('utf-8'))))),
459+
('include_synonyms', Boolean)
460+
)
461+
462+
class DescribeConfigsResponse_v0(Response):
463+
API_KEY = 32
464+
API_VERSION = 0
465+
SCHEMA = Schema(
466+
('throttle_time_ms', Int32),
467+
('resources', Array(
468+
('error_code', Int16),
469+
('error_message', String('utf-8')),
470+
('resource_type', Int8),
471+
('resource_name', String('utf-8')),
472+
('config_entries', Array(
473+
('config_names', String('utf-8')),
474+
('config_value', String('utf-8')),
475+
('read_only', Boolean),
476+
('is_default', Boolean),
477+
('is_sensitive', Boolean)))))
478+
)
479+
480+
class DescribeConfigsResponse_v1(Response):
481+
API_KEY = 32
482+
API_VERSION = 1
483+
SCHEMA = Schema(
484+
('throttle_time_ms', Int32),
485+
('resources', Array(
486+
('error_code', Int16),
487+
('error_message', String('utf-8')),
488+
('resource_type', Int8),
489+
('resource_name', String('utf-8')),
490+
('config_entries', Array(
491+
('config_names', String('utf-8')),
492+
('config_value', String('utf-8')),
493+
('read_only', Boolean),
494+
('is_default', Boolean),
495+
('is_sensitive', Boolean),
496+
('config_synonyms', Array(
497+
('config_name', String('utf-8')),
498+
('config_value', String('utf-8')),
499+
('config_source', Int8)))))))
500+
)
501+
502+
DescribeConfigsRequest = [DescribeConfigsRequest_v0, DescribeConfigsRequest_v1]
503+
DescribeConfigsResponse = [DescribeConfigsResponse_v0, DescribeConfigsResponse_v1]
313504

314505
class SaslAuthenticateResponse_v0(Request):
315506
API_KEY = 36

0 commit comments

Comments
 (0)