streamnative/pulsar-rs

在使用正则订阅的时候提示没有权限

Opened this issue · 0 comments

我在我的项目中添加了依赖:

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:

为什么会收到这个错误?是哪里没有正确的配置的原因吗?但是使用非正则订阅却是正常的,能正常订阅也能接收到消息。