fix(wolff_producer): log message format string and arg list mismatch

kafka4beam · Aug 3, 2023 · 3f42a97 · 3f42a97
1 parent b40632f
commit 3f42a97
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/wolff.appup.src b/src/wolff.appup.src
@@ -4,6 +4,7 @@
     {"1.5.10",
      [ {load_module, wolff_client, brutal_purge, soft_purge, []}
      , {load_module, wolff_producers, brutal_purge, soft_purge, []}
+     , {load_module, wolff_producer, brutal_purge, soft_purge, []}
      ]},
     {"1.5.9",
      [ {load_module, wolff_client, brutal_purge, soft_purge, []}
@@ -36,6 +37,7 @@
     {"1.5.10",
      [ {load_module, wolff_client, brutal_purge, soft_purge, []}
      , {load_module, wolff_producers, brutal_purge, soft_purge, []}
+     , {load_module, wolff_producer, brutal_purge, soft_purge, []}
      ]},
     {"1.5.9",
      [ {load_module, wolff_client, brutal_purge, soft_purge, []}

diff --git a/src/wolff_producer.erl b/src/wolff_producer.erl
@@ -451,7 +451,7 @@ handle_kafka_ack(#kpro_rsp{api = produce,
       do_handle_kafka_ack(Ref, BaseOffset, St);
     false ->
       #{topic := Topic, partition := Partition} = St,
-      log_warn(Topic, Partition, "~s-~p: Produce response error-code = ~0p", [ErrorCode]),
+      log_warn(Topic, Partition, "Produce response error-code = ~0p", [ErrorCode]),
       erlang:throw(ErrorCode)
   end.