File tree Expand file tree Collapse file tree 3 files changed +13
-0
lines changed Expand file tree Collapse file tree 3 files changed +13
-0
lines changed Original file line number Diff line number Diff line change 1+ KafkaAdmin
2+ ===========
3+
4+ .. autoclass :: kafka.admin.KafkaAdmin
5+ :members:
Original file line number Diff line number Diff line change @@ -5,6 +5,7 @@ kafka-python API
55
66 KafkaConsumer
77 KafkaProducer
8+ KafkaAdmin
89 KafkaClient
910 BrokerConnection
1011 ClusterMetadata
Original file line number Diff line number Diff line change 1818class KafkaAdmin (object ):
1919 """An class for administering the kafka cluster.
2020
21+ Warning:
22+ This is an unstable interface that was recently added and is subject to
23+ change without warning. In particular, many methods currently return
24+ raw protocol tuples. In future releases, we plan to make these into
25+ nicer, more pythonic objects. Unfortunately, this will likely break
26+ those interfaces.
27+
2128 The KafkaAdmin class will negotiate for the latest version of each message protocol format supported
2229 by both the kafka-python client library and the kafka broker. Usage of optional fields from protocol
2330 versions that are not supported by the broker will result in UnsupportedVersionError exceptions.
You can’t perform that action at this time.
0 commit comments