chore: inspect client name on logs

oliveigah · Nov 23, 2024 · 526ecbb · 526ecbb
1 parent 37321c2
commit 526ecbb
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git 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
@@ -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
@@ -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