Merge pull request #929 from carsonip/fix-managed-balanced-consumer

Fix wrong default compacted_topic of ManagedBalancedConsumer
Parsely · Mar 18, 2019 · 5846875 · 5846875
2 parents 3893c46 + a2b1ee5
commit 5846875
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pykafka/managedbalancedconsumer.py b/pykafka/managedbalancedconsumer.py
@@ -71,7 +71,7 @@ def __init__(self,
                  reset_offset_on_start=False,
                  post_rebalance_callback=None,
                  use_rdkafka=False,
-                 compacted_topic=True,
+                 compacted_topic=False,
                  heartbeat_interval_ms=3000,
                  membership_protocol=RangeProtocol,
                  deserializer=None,