Skip to content

Commit

Permalink
Document KafkaAdmin class
Browse files Browse the repository at this point in the history
  • Loading branch information
jeffwidman committed Oct 29, 2018
1 parent f00016e commit cdfbb95
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 0 deletions.
5 changes: 5 additions & 0 deletions docs/apidoc/KafkaAdmin.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
KafkaAdmin
===========

.. autoclass:: kafka.admin.KafkaAdmin
:members:
7 changes: 7 additions & 0 deletions kafka/admin/kafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,13 @@
class KafkaAdmin(object):
"""An class for administering the kafka cluster.
Warning:
This is an unstable interface that was recently added and is subject to
change without warning. In particular, many methods currently return
raw protocol tuples. In future releases, we plan to make these into
nicer, more pythonic objects. Unfortunately, this will likely break
those interfaces.
The KafkaAdmin class will negotiate for the latest version of each message protocol format supported
by both the kafka-python client library and the kafka broker. Usage of optional fields from protocol
versions that are not supported by the broker will result in UnsupportedVersionError exceptions.
Expand Down

0 comments on commit cdfbb95

Please sign in to comment.