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 0316796 commit cd2f2c1Copy full SHA for cd2f2c1
sources/kafka/__init__.py
@@ -50,7 +50,7 @@ def kafka_consumer(
50
is taken from secrets.
51
msg_processor(Optional[Callable]): A function-converter,
52
which'll process every Kafka message after it's read and
53
- before it's transfered to the destination.
+ before it's transferred to the destination.
54
batch_size (Optional[int]): Messages batch size to read at once.
55
batch_timeout (Optional[int]): Maximum time to wait for a batch
56
consume, in seconds.
0 commit comments