yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: check `brod_sup` for client id

This commit is contained in:
Thales Macedo Garitezi 2024-02-29 09:53:23 -03:00
parent 6b9844ae82
commit 0aa9a872a3
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_consumer.erl
View File

@ -210,9 +210,15 @@ on_stop(ConnectorResId, State) ->
?tp(kafka_consumer_subcriber_and_client_stopped, #{instance_id => ConnectorResId}), ?tp(kafka_consumer_subcriber_and_client_stopped, #{instance_id => ConnectorResId}),
ok. ok.
-spec on_get_status(resource_id(), connector_state()) -> connected | disconnected. -spec on_get_status(connector_resource_id(), connector_state()) ->
on_get_status(_ResourceID, _State) -> ?status_connected | ?status_disconnected.
?status_connected. on_get_status(_ConnectorResId, _State = #{kafka_client_id := ClientID}) ->
case brod_sup:find_client(ClientID) of
[_Pid] -> ?status_connected;
_ -> ?status_disconnected
end;
on_get_status(_ConnectorResId, _State) ->
?status_disconnected.
-spec on_add_channel( -spec on_add_channel(
connector_resource_id(), connector_resource_id(),