From 0da5a5587cbe66b00679bf6810cc6641e78488cc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andr=C3=A9=20Portela?= Date: Thu, 13 Aug 2020 10:57:10 -0400 Subject: [PATCH] docstring for header support in Producer.send closes #566 --- aiokafka/producer/producer.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/aiokafka/producer/producer.py b/aiokafka/producer/producer.py index 9ecc5ea5..7ca8c462 100644 --- a/aiokafka/producer/producer.py +++ b/aiokafka/producer/producer.py @@ -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