操作场景
TDMQ Pulsar 版提供和原生 Pulsar 一样的 JWT 鉴权方式,用户可以通过在客户端参数中配置 Token 的方式来访问对应的 TDMQ Pulsar 版资源。关于如何配置不同角色 Token 与 TDMQ Pulsar 版资源的关系,需要在控制台上进行操作,详细步骤请参见 角色与权限。 本文主要讲述如何在 TDMQ Pulsar 版客户端中配置 JWT 鉴权,以方便您安全地使用 TDMQ Pulsar 版的 Client 对接 TDMQ Pulsar 版进行消息的生产消费(您可以在创建 Client 的时候添加密钥)。
鉴权配置
Java 客户端
在 Java 客户端中配置 JWT 鉴权:
PulsarClient client = PulsarClient.builder()
.serviceUrl("http://*")
.authentication(AuthenticationFactory.token("eyJh****"))
.build();
PulsarClient client = PulsarClient.builder()
.serviceUrl("pulsar://*.*.*.*:6000/")
.authentication(AuthenticationFactory.token("eyJh****"))
.listenerName("custom:1********0/vpc-******/subnet-********")
.build();
Go 客户端
在 Go 客户端中配置 JWT 鉴权:
client, err := NewClient(ClientOptions{
URL: "http://*",
Authentication: NewAuthenticationToken("eyJh****"),
})
client, err := NewClient(ClientOptions{
URL: "pulsar://*.*.*.*:6000",
Authentication: NewAuthenticationToken("eyJh****"),
ListenerName: "custom:1300*****0/vpc-******/subnet-********",
})
本页内容是否解决了您的问题?