oslo.messaging/oslo_messaging
Andy Smith 5a842ae155 Switch driver to confluent-kafka client library
This patch switches the kafka python client from kafka-python to
confluent-kafka due to documented threading issues with the
kafka-python consumer and the recommendation to use multiplrocessing.
The confluent-kafka client leverages the high performance librdkafka
C client and is safe for multiple thread use.

This patch:
* switches to confluent-kafka library
* revises consumer and producer message operations
* utilizes event.tpool method for confluent-kafka blocking calls
* updates unit tests
* adds kafka specific timeouts for functional tests
* adds release note

Depends-On: Ice374dca539b8ed1b1965b75379bad5140121483
Change-Id: Idfb9fe3700d882c8285c6dc56b0620951178eba2
2018-12-04 11:25:07 -05:00
..
_drivers Switch driver to confluent-kafka client library 2018-12-04 11:25:07 -05:00
hacking Test:Use unittest.mock on Python 3 2017-02-08 19:15:17 +08:00
notify Remove transport aliases support 2018-07-05 15:58:05 +10:00
rpc Issue blocking ACK for RPC requests from the consumer thread 2018-07-11 08:59:35 -04:00
tests Switch driver to confluent-kafka client library 2018-12-04 11:25:07 -05:00
__init__.py Remove deprecated localcontext 2016-05-18 09:28:15 +02:00
_i18n.py Update URLs in documents according to document migration 2017-07-12 22:54:02 +08:00
_utils.py Use method fetch_current_thread_functor from oslo.utils 2016-09-24 15:22:44 +08:00
conffixture.py Allow transport_url initialization in ConfFixture constructor 2018-10-09 13:46:00 -04:00
dispatcher.py Remove useless logging import statements 2016-11-08 10:11:13 +08:00
exceptions.py Move files out of the namespace package 2015-01-12 12:50:41 -05:00
opts.py Remove the deprecated ZeroMQ driver 2018-08-28 16:00:50 -04:00
serializer.py serializer: remove deprecated RequestContextSerializer 2017-03-29 16:21:17 +08:00
server.py Call listener stop only if listener is initialized 2018-08-02 13:28:42 +02:00
target.py Fixups to the inline documentation 2016-09-12 09:49:00 -04:00
transport.py Fix oslo.messaging default transport 2018-10-05 15:21:45 +02:00
version.py pbr.version.VersionInfo needs package name (oslo.xyz and not oslo_xyz) 2017-02-06 12:49:23 -05:00