diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/client.py b/kafka/client.py index 38136af..8e62e0d 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -132,8 +132,8 @@ class KafkaClient(object): Params ====== - payloads: list of object-like entities with a topic and - partition attribute + payloads: list of object-like entities with a topic (str) and + partition (int) attribute encode_fn: a method to encode the list of payloads to a request body, must accept client_id, correlation_id, and payloads as keyword arguments |