@@ -37,20 +37,6 @@ class KafkaAdminClient(
3737):
3838 """A class for administering the Kafka cluster.
3939
40- Warning:
41- This is an unstable interface that was recently added and is subject to
42- change without warning. In particular, many methods currently return
43- raw protocol tuples. In future releases, we plan to make these into
44- nicer, more pythonic objects. Unfortunately, this will likely break
45- those interfaces.
46-
47- The KafkaAdminClient class will negotiate for the latest version of each message
48- protocol format supported by both the kafka-python client library and the
49- Kafka broker. Usage of optional fields from protocol versions that are not
50- supported by the broker will result in IncompatibleBrokerVersion exceptions.
51-
52- Use of this class requires a minimum broker version >= 0.10.0.0.
53-
5440 Keyword Arguments:
5541 bootstrap_servers: 'host[:port]' string (or list of 'host[:port]'
5642 strings) that the consumer should contact to bootstrap initial
@@ -137,6 +123,7 @@ class KafkaAdminClient(
137123 Examples::
138124
139125 (4, 3) most recent broker release, enable all supported features
126+ (2, 7) support SCRAM user credential apis
140127 (0, 11) enables message format v2 (internal)
141128 (0, 10, 0) enables sasl authentication and message format v1
142129 (0, 9) enables full group coordination features with automatic
0 commit comments