diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-04-05 22:54:28 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-04-05 22:54:28 -0700 |
| commit | 90c729438a2e3f1b194e58231e41bd16bd7b7172 (patch) | |
| tree | b22cef6b10fd167fb22b8318e1294f6137427f3b /kafka/producer/sender.py | |
| parent | 452e7c2190b83f320f58e7f650302696dde458ed (diff) | |
| download | kafka-python-protocol_versions.tar.gz | |
Use version-indexed lists for request/response protocol structsprotocol_versions
Diffstat (limited to 'kafka/producer/sender.py')
| -rw-r--r-- | kafka/producer/sender.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py index 3cafb26..2201261 100644 --- a/kafka/producer/sender.py +++ b/kafka/producer/sender.py @@ -12,8 +12,6 @@ from ..structs import TopicPartition from ..version import __version__ from ..protocol.produce import ProduceRequest - - log = logging.getLogger(__name__) @@ -258,7 +256,7 @@ class Sender(threading.Thread): buf = batch.records.buffer() produce_records_by_partition[topic][partition] = buf - return ProduceRequest( + return ProduceRequest[0]( required_acks=acks, timeout=timeout, topics=[(topic, list(partition_info.items())) |