diff --git a/lib/klife/connection/controller.ex b/lib/klife/connection/controller.ex index ca8f98f..f986bae 100644 --- a/lib/klife/connection/controller.ex +++ b/lib/klife/connection/controller.ex @@ -308,7 +308,7 @@ defmodule Klife.Connection.Controller do def disable_feature(:producer = feature, client_name) do Logger.warning(""" - Producer feature will be disabled. + Producer feature will be disabled for client #{inspect(client_name)}. This may happen because of: - API version negotiation failures @@ -321,7 +321,7 @@ defmodule Klife.Connection.Controller do def disable_feature(:txn_producer = feature, client_name) do Logger.warning(""" - Transactions feature will be disabled. + Transactions feature will be disabled for client #{inspect(client_name)}. This may happen because of: - API version negotiation failures @@ -334,7 +334,7 @@ defmodule Klife.Connection.Controller do def disable_feature(:producer_idempotence = feature, client_name) do Logger.warning(""" - Producer idempotence feature will be disabled . + Producer idempotence feature will be disabled for client #{inspect(client_name)}. This may happen because of: - API version negotiation failures @@ -346,7 +346,7 @@ defmodule Klife.Connection.Controller do def disable_feature(:sasl = feature, client_name) do Logger.warning(""" - SASL feature will be disabled. + SASL feature will be disabled for client #{inspect(client_name)}. This may happen because of: - API version negotiation failures diff --git a/lib/klife/producer/dispatcher.ex b/lib/klife/producer/dispatcher.ex index 06e9d6d..c8d8021 100644 --- a/lib/klife/producer/dispatcher.ex +++ b/lib/klife/producer/dispatcher.ex @@ -201,7 +201,7 @@ defmodule Klife.Producer.Dispatcher do partition: #{partition} error_code: #{error_code} - client: #{client_name} + client: #{inspect(client_name)} broker_id: #{broker_id} producer_name: #{producer_name} """) diff --git a/lib/klife/producer/producer.ex b/lib/klife/producer/producer.ex index c4e3709..c435c2e 100644 --- a/lib/klife/producer/producer.ex +++ b/lib/klife/producer/producer.ex @@ -368,7 +368,7 @@ defmodule Klife.Producer do {:ok, %{content: %{error_code: ec}}} -> Logger.error( - "Error code #{ec} returned from broker for client #{state.client_name} on #{inspect(M.InitProducerId)} call" + "Error code #{ec} returned from broker for client #{inspect(state.client_name)} on #{inspect(M.InitProducerId)} call" ) :retry @@ -403,7 +403,7 @@ defmodule Klife.Producer do {:ok, %{content: %{error_code: ec}}} -> Logger.error( - "Error code #{ec} returned from broker for client #{state.client_name} on #{inspect(M.FindCoordinator)} call" + "Error code #{ec} returned from broker for client #{inspect(state.client_name)} on #{inspect(M.FindCoordinator)} call" ) :retry