We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
We should close the consumer when TopicNotFound. #1134
According to the JAVA client, when TopicNotFound, the consumer is set to state Failed and close.
see: https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java#L915-L917
Currently, we just stop reconnecting, see: https://github.com/apache/pulsar-client-go/blob/master/pulsar/consumer_partition.go#L1662-L1666
How can we reproduce the issue
Pulsar version: x.y
The text was updated successfully, but these errors were encountered:
@RobertIndie
Sorry, something went wrong.
No branches or pull requests
Expected behavior
We should close the consumer when TopicNotFound. #1134
According to the JAVA client, when TopicNotFound, the consumer is set to state Failed and close.
see:
https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java#L915-L917
Actual behavior
Currently, we just stop reconnecting, see:
https://github.com/apache/pulsar-client-go/blob/master/pulsar/consumer_partition.go#L1662-L1666
Steps to reproduce
How can we reproduce the issue
System configuration
Pulsar version: x.y
The text was updated successfully, but these errors were encountered: