We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1afa214 commit 232c4cfCopy full SHA for 232c4cf
faust/transport/drivers/aiokafka.py
@@ -1563,9 +1563,9 @@ async def _really_create_topic(
1563
return
1564
response = wait_result.result
1565
1566
- assert len(response.topic_error_codes), "single topic"
+ assert len(response.topic_errors), "single topic"
1567
1568
- _, code, reason = response.topic_error_codes[0]
+ _, code, reason = response.topic_errors[0]
1569
1570
if code != 0:
1571
if not ensure_created and code == TopicExistsError.errno:
requirements/requirements.txt
@@ -1,6 +1,6 @@
1
aiohttp>=3.8.0,<4.0
2
aiohttp_cors>=0.7,<2.0
3
-aiokafka>=0.9.0
+aiokafka>=0.10.0
4
click>=6.7,<8.2
5
mode-streaming>=0.4.0
6
opentracing>=1.3.0,<=2.4.0
0 commit comments