Witek Bedyk eb8e6ff7e2 Allow passing config options to Kafka producer ...

The change allows passing supported options as dictionary to create a
Kafka producer object.

Change-Id: I7627a8caa2d6bb9c7789df143e72a4085060b164
Story: 2006059
Task: 37531

2019-11-18 11:06:12 +01:00

..

__init__.py

Add wrapper for Confluent Kafka async Producer

2018-11-28 09:56:34 +01:00

consumer.py

Confluent Kafka driver broker option bug

2019-08-10 16:29:14 +02:00

producer.py

Allow passing config options to Kafka producer

2019-11-18 11:06:12 +01:00