Skip to content

Commit

Permalink
docstring for header support in Producer.send
Browse files Browse the repository at this point in the history
  • Loading branch information
andreportela authored Aug 13, 2020
1 parent 84e2a98 commit 0da5a55
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions aiokafka/producer/producer.py
Original file line number Diff line number Diff line change
Expand Up @@ -396,6 +396,9 @@ async def send(
key_serializer.
timestamp_ms (int, optional): epoch milliseconds (from Jan 1 1970
UTC) to use as the message timestamp. Defaults to current time.
headers (optional): Kafka headers to be included in the message using
the format [("key", b"value")]. Iterable of tuples where key is a
normal string and value is a byte string.
Returns:
asyncio.Future: object that will be set when message is
Expand Down

0 comments on commit 0da5a55

Please sign in to comment.