diff options
| author | Andy Smith <ansmith@redhat.com> | 2018-09-17 13:21:42 -0400 |
|---|---|---|
| committer | Andy Smith <ansmith@redhat.com> | 2018-12-04 11:25:07 -0500 |
| commit | 5a842ae15582e4eedfb1b2510eaf4a8997701f58 (patch) | |
| tree | 283024cba8b0b6b736f85978aba5568280af1d51 /doc | |
| parent | 252844879d9e34c81b1777a92ad4407fab4a6853 (diff) | |
| download | oslo-messaging-5a842ae15582e4eedfb1b2510eaf4a8997701f58.tar.gz | |
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
Diffstat (limited to 'doc')
| -rw-r--r-- | doc/requirements.txt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/doc/requirements.txt b/doc/requirements.txt index 5d126f7..9df2d5b 100644 --- a/doc/requirements.txt +++ b/doc/requirements.txt @@ -8,6 +8,6 @@ reno>=2.5.0 # Apache-2.0 # imported when the source code is parsed for generating documentation: fixtures>=3.0.0 # Apache-2.0/BSD -kafka-python>=1.3.1 # Apache-2.0 +confluent-kafka>=0.11.6 # Apache-2.0 pyngus>=2.2.0 # Apache-2.0 tenacity>=3.2.1 # Apache-2.0 |