Turn on zstd compression by default

nasa-gcn · Oct 7, 2022 · 15cb72e · 15cb72e
1 parent 93e4208
commit 15cb72e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/gcn_kafka/core.py b/gcn_kafka/core.py
@@ -48,6 +48,9 @@ def get_config(mode, config, **kwargs):
     if mode == "consumer" and not config.get("group.id"):
         config["group.id"] = str(uuid4())
 
+    if mode == "producer":
+        config.setdefault('compression.type', 'zstd')
+
     set_oauth_cb(config)
     return config