|
22 | 22 | TopicCollection, IsolationLevel,
|
23 | 23 | ConsumerGroupType, ElectionType)
|
24 | 24 | from confluent_kafka.admin import (AdminClient, NewTopic, NewPartitions, ConfigResource,
|
25 |
| - ConfigEntry, ConfigSource, AclBinding, |
| 25 | + ConfigEntry, ConfigSource, ConfigType, AclBinding, |
26 | 26 | AclBindingFilter, ResourceType, ResourcePatternType,
|
27 | 27 | AclOperation, AclPermissionType, AlterConfigOpType,
|
28 | 28 | ScramMechanism, ScramCredentialInfo,
|
@@ -103,13 +103,13 @@ def example_create_partitions(a, topics):
|
103 | 103 |
|
104 | 104 |
|
105 | 105 | def print_config(config, depth):
|
106 |
| - print('%40s = %-50s [%s,is:read-only=%r,default=%r,sensitive=%r,synonym=%r,synonyms=%s,type=%r, documentation=%s]' % |
| 106 | + print('%40s = %-50s [%s,is:read-only=%r,default=%r,sensitive=%r,synonym=%r,synonyms=%s,type=%s, documentation=%s]' % |
107 | 107 | ((' ' * depth) + config.name, config.value, ConfigSource(config.source),
|
108 | 108 | config.is_read_only, config.is_default,
|
109 | 109 | config.is_sensitive, config.is_synonym,
|
110 | 110 | ["%s:%s" % (x.name, ConfigSource(x.source))
|
111 | 111 | for x in iter(config.synonyms.values())],
|
112 |
| - config.type, config.documentation)) |
| 112 | + ConfigType(config.type), config.documentation)) |
113 | 113 |
|
114 | 114 |
|
115 | 115 | def example_describe_configs(a, args):
|
|
0 commit comments