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 0b195df66..2bd44d16a 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
@@ -137,7 +137,10 @@ on_get_status(_InstanceId, State) ->
             disconnected
     end.
 
--spec on_query(manager_id(), {send_message, map()}, state()) -> ok | {error, timeout}.
+-spec on_query(manager_id(), {send_message, map()}, state()) ->
+    {ok, term()}
+    | {error, timeout}
+    | {error, term()}.
 on_query(_InstanceId, {send_message, Message}, State) ->
     #{
         producers := Producers,