在使用正则订阅的时候提示没有权限
Opened this issue · 0 comments
a11enhuang commented
我在我的项目中添加了依赖:
pulsar = "6.1.0"
然后尝试使用正则表达式的方式订阅消息
self.client.consumer()
.with_subscription(subscription_name)
.with_subscription_type(option.sub_type.unwrap_or(pulsar::SubType::Shared))
.replace_topic(topic_regex)
.with_subscription_type(pulsar::SubType::Exclusive)
.with_options(ConsumerOptions::default().durable(false));
但是我会收到错误:
called `Result::unwrap()` on an `Err` value: Connection(PulsarError(Some(AuthorizationError), Some("Proxy Client is not authorized to GetTopicsOfNamespace")))
stack backtrace:
为什么会收到这个错误?是哪里没有正确的配置的原因吗?但是使用非正则订阅却是正常的,能正常订阅也能接收到消息。