Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

restart Pulsar bookie,Pulsar conn closed,but Pulsar-client-erl not reconnect #60

Open
hellcox opened this issue Jan 12, 2024 · 0 comments

Comments

@hellcox
Copy link

hellcox commented Jan 12, 2024

emqx v5 5.2.1 pulgin use pulsar-client-erl.
old use tag: 0.7.1 (this version is ok).
change use tag:0.8.3 (this not ok).

Send messages to persistent://xxx/iot_raw_normal/q_emqx_stat_msg_old at a rate of 3 messages per second.
when restart pulsar bookie, got log:

2024-01-10T09:03:58.771530+00:00 [error] [pulsar-producer][persistent://xxx/iot_raw_normal/q_emqx_stat_msg_old] Close producer: "persistent://xxx/iot_raw_normal/q_emqx_stat_msg_old"
2024-01-10T09:03:58.771862+00:00 [error] parse unknown type:#{send_error => #{error => 'PersistenceError',message => "org.apache.bookkeeper.mledger.ManagedLedgerException: Not enough non-faulty bookies available",producer_id => 1,sequence_id => 14712},type => 'SEND_ERROR'}
2024-01-10T09:03:58.772501+00:00 [error] [pulsar-producer][persistent://xxx/iot_raw_normal/q_emqx_stat_msg_old] Receive unknown message:unknown

then use netstat -anp |grep 6650 , no conn found,and pulsar-client-erl not try to reconnect.

code:

{ok, ClientPid} = pulsar:ensure_supervised_client(ClientName, Urls, Opts),
{ok, Producers} = pulsar:ensure_supervised_producers(ClientName, PulsarTopic, ProducerOpts),
Send = pulsar:send(Producers, [#{key => "", value => Msg}]),
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant