Pulsar客户端错误-无法加载身份验证插件



当尝试在本地运行脉冲星客户端consume命令时,我得到了错误:

未能加载身份验证插件

这是我运行的命令:

./pulsar-client consume persistent://data-log/ingest/data-log-kafka -s damo

我配置了一个client.conf,下面列出了脉冲星的完整"堆栈轨迹"。我看不出我错过了什么

Failed to load an authentication plugin
Usage: pulsar-client [options] [command] [command options]
Options:
--auth-params
Authentication parameters, e.g., "key1:val1,key2:val2".
Default: token:eyJh##############################
--auth-plugin
Authentication plugin class name.
Default: org.apache.pulsar.client.impl.auth.AuthenticationToken 
-h, --help
Show this help.
Default: false
--url
Broker URL to which to connect.
Default: pulsar+ssl://aaa-bbb-ccc-ms-tls.acme.com:6651
Commands:
consume      Consume messages from a specified topic
Usage: consume [options] TopicName
Options:
--hex
Display binary messages in hex.
Default: false
-n, --num-messages
Number of messages to consume, 0 means to consume forever.
Default: 1
-r, --rate
Rate (in msg/sec) at which to consume, value 0 means to consume
messages as fast as possible.
Default: 0.0
* -s, --subscription-name
Subscription name.
-t, --subscription-type
Subscription type: Exclusive, Shared, Failover.
Default: Exclusive
Possible Values: [Exclusive, Shared, Failover]

任何提示都将不胜感激!感谢

问题是我使用的是旧版本的脉冲星,在2.5.0上运行良好。哦!!!!

最新更新