restart consumer group together with manager consumer group

kafkaex · May 19, 2019 · ec9299b · ec9299b
1 parent 60ac0a2
commit ec9299b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafka_ex/consumer_group.ex b/lib/kafka_ex/consumer_group.ex
@@ -349,7 +349,7 @@ defmodule KafkaEx.ConsumerGroup do
       )
     ]
 
-    supervise(children, strategy: :one_for_all)
+    supervise(children, strategy: :one_for_all, max_restarts: 0, max_seconds: 1)
   end
 
   defp call_manager(supervisor_pid, call) do