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 5ca377a commit 6b4ce80Copy full SHA for 6b4ce80
README.md
@@ -15,7 +15,7 @@ async def test() -> None:
15
16
## Configuration
17
18
-AioKafkaBroker parameters:
+AioKafkaBroker parameters:
19
* `bootstrap_servers` - url to kafka nodes. Can be either string or list of strings.
20
* `kafka_topic` - custom topic in kafka.
21
* `result_backend` - custom result backend.
taskiq_aio_kafka/broker.py
@@ -117,7 +117,7 @@ def __init__( # noqa: WPS211
117
118
self._is_started = False
119
120
- async def startup(self) -> None: # noqa: C901
+ async def startup(self) -> None:
121
"""Setup AIOKafkaProducer, AIOKafkaConsumer and kafka topics.
122
123
We will have 2 topics for default and high priority.
0 commit comments