diff --git a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl
index 4bc390b91..72363389e 100644
--- a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl
+++ b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl
@@ -92,12 +92,12 @@ on_start(InstanceId, Config) ->
                 instance_id => InstanceId,
                 pulsar_hosts => Servers
             });
-        {error, Error} ->
+        {error, Reason} ->
             ?SLOG(error, #{
-                msg => "failed_to_start_kafka_client",
+                msg => "failed_to_start_pulsar_client",
                 instance_id => InstanceId,
                 pulsar_hosts => Servers,
-                reason => Error
+                reason => Reason
             }),
             throw(failed_to_start_pulsar_client)
     end,