Skip to content

Commit

Permalink
Minor docstring fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
tvoinarovskyi committed Nov 6, 2016
1 parent ea02599 commit b5612a0
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion aiokafka/producer.py
Original file line number Diff line number Diff line change
Expand Up @@ -265,9 +265,14 @@ def send(self, topic, value=None, key=None, partition=None):
key_serializer.
Returns:
`asyncio.Future` object that will be set when message is
asyncio.Future: object that will be set when message is
processed
Raises:
kafka.KafkaTimeoutError: if we can't schedule this record (
pending buffer is full) in up to `request_timeout_ms`
milliseconds.
Note:
The returned future will wait based on `request_timeout_ms`
setting. Cancelling the returned future **will not** stop event
Expand Down

0 comments on commit b5612a0

Please sign in to comment.