chore: fix error message and rename variable
This commit is contained in:
parent
180b6acd9e
commit
1e8dd70a11
|
@ -92,12 +92,12 @@ on_start(InstanceId, Config) ->
|
||||||
instance_id => InstanceId,
|
instance_id => InstanceId,
|
||||||
pulsar_hosts => Servers
|
pulsar_hosts => Servers
|
||||||
});
|
});
|
||||||
{error, Error} ->
|
{error, Reason} ->
|
||||||
?SLOG(error, #{
|
?SLOG(error, #{
|
||||||
msg => "failed_to_start_kafka_client",
|
msg => "failed_to_start_pulsar_client",
|
||||||
instance_id => InstanceId,
|
instance_id => InstanceId,
|
||||||
pulsar_hosts => Servers,
|
pulsar_hosts => Servers,
|
||||||
reason => Error
|
reason => Reason
|
||||||
}),
|
}),
|
||||||
throw(failed_to_start_pulsar_client)
|
throw(failed_to_start_pulsar_client)
|
||||||
end,
|
end,
|
||||||
|
|
Loading…
Reference in New Issue