Skip to content

Commit 7bde919

Browse files
committed
Use correct casing for MB
These values refer to Megabytes, not Megabits. Fix #1295
1 parent a3995b3 commit 7bde919

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

kafka/consumer/fetcher.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ def __init__(self, client, subscriptions, metrics, **configs):
8585
performs fetches to multiple brokers in parallel so memory
8686
usage will depend on the number of brokers containing
8787
partitions for the topic.
88-
Supported Kafka version >= 0.10.1.0. Default: 52428800 (50 Mb).
88+
Supported Kafka version >= 0.10.1.0. Default: 52428800 (50 MB).
8989
max_partition_fetch_bytes (int): The maximum amount of data
9090
per-partition the server will return. The maximum total memory
9191
used for a request = #partitions * max_partition_fetch_bytes.

kafka/consumer/group.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ class KafkaConsumer(six.Iterator):
7474
ensure that the consumer can make progress. NOTE: consumer performs
7575
fetches to multiple brokers in parallel so memory usage will depend
7676
on the number of brokers containing partitions for the topic.
77-
Supported Kafka version >= 0.10.1.0. Default: 52428800 (50 Mb).
77+
Supported Kafka version >= 0.10.1.0. Default: 52428800 (50 MB).
7878
max_partition_fetch_bytes (int): The maximum amount of data
7979
per-partition the server will return. The maximum total memory
8080
used for a request = #partitions * max_partition_fetch_bytes.

0 commit comments

Comments
 (0)