Rewrite the 1MB message limit

Gabriel Tincu · Gabriel Tincu · commit 3372b100cfbe · 2020-03-26T13:22:55.000+01:00
diff --git a/kafka/codec.py b/kafka/codec.py
@@ -10,7 +10,7 @@
 
 _XERIAL_V1_HEADER = (-126, b'S', b'N', b'A', b'P', b'P', b'Y', 0, 1, 1)
 _XERIAL_V1_FORMAT = 'bccccccBii'
-ZSTD_MAX_OUTPUT_SIZE = 1024 ** 2
+ZSTD_MAX_OUTPUT_SIZE = 1024 * 1024
 
 try:
     import snappy
