diff --git a/lib/kafka_ex/consumer_group/manager.ex b/lib/kafka_ex/consumer_group/manager.ex index 691d9604..bc45237f 100644 --- a/lib/kafka_ex/consumer_group/manager.ex +++ b/lib/kafka_ex/consumer_group/manager.ex @@ -339,10 +339,17 @@ defmodule KafkaEx.ConsumerGroup.Manager do member_id: member_id, } - %LeaveGroupResponse{error_code: :no_error} = + leave_group_response = KafkaEx.leave_group(leave_request, worker_name: worker_name) - Logger.debug(fn -> "Left consumer group #{group_name}" end) + if leave_group_response.error_code == :no_error do + Logger.debug(fn -> "Left consumer group #{group_name}" end) + else + Logger.warn(fn -> + "Received error #{inspect leave_group_response.error_code}, " <> + "consumer group manager will exit regardless." + end) + end :ok end