ProduceToTopic does not allow to add custom headers to messages

astronomer / airflow-provider-kafka

A provider package for kafka

Apache License 2.0

37 stars 16 forks source link

Open nikitasharma1108 opened 1 year ago

nikitasharma1108 commented 1 year ago

ProduceToTopic.py line 118 for k, v in producer_callable(): producer.produce( self.topic, key=k, value=v, on_delivery=self.delivery_callback )

does not pass headers, so unable to send custom headers with messages

dylanbstorey commented 1 year ago

we accept pull requests.

nikitasharma1108 commented 1 year ago

I have sent a Pull request