Be more defensive when checking for consumer group retry count

kafkaex · Apr 6, 2020 · 4444c96 · 4444c96
1 parent 65275ab
commit 4444c96
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafka_ex/consumer_group/manager.ex b/lib/kafka_ex/consumer_group/manager.ex
@@ -281,7 +281,7 @@ defmodule KafkaEx.ConsumerGroup.Manager do
         on_successful_join(state, join_response)
 
       {:error, :no_broker} ->
-        if attempt_number == @max_join_retries do
+        if attempt_number >= @max_join_retries do
           raise "Unable to join consumer group #{state.group_name} after " <>
                   "#{@max_join_retries} attempts"
         end