diff --git a/src/wolff.appup.src b/src/wolff.appup.src index 61f20ec..49f9c7b 100644 --- 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 index b977528..4cad86c 100644 --- 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.