Skip to content

Commit ef3f172

Browse files
committed
Bound kafka client version
Starting with 2.0.4, the errors module does not expose a tuple of retriable errors: instead there is an attribute on each error type. Making journalpump compatible with both the old and new version is outside the scope of this change, so bound the kafka client version.
1 parent ec7f967 commit ef3f172

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
kafka-python
1+
kafka-python<2.0.4
22
requests
33
websockets
44
aiohttp-socks

setup.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
packages=find_packages(exclude=["test", "systest"]),
1111
extras_require={},
1212
install_requires=[
13-
"kafka-python",
13+
"kafka-python<2.0.4",
1414
"requests",
1515
"websockets",
1616
"aiohttp-socks",

0 commit comments

Comments
 (0)