- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- Getting Started
- Developer Guide
- Operation Guide
- Practical Tutorial
- API Documentation
- History
- Introduction
- API Category
- Making API Requests
- Message APIs
- Cluster APIs
- Namespace APIs
- Topic APIs
- CMQ Message APIs
- CMQ Management APIs
- UnbindCmqDeadLetter
- RewindCmqQueue
- ModifyCmqTopicAttribute
- ModifyCmqSubscriptionAttribute
- ModifyCmqQueueAttribute
- DescribeCmqTopics
- DescribeCmqTopicDetail
- DescribeCmqSubscriptionDetail
- DescribeCmqQueues
- DescribeCmqQueueDetail
- DeleteCmqTopic
- DeleteCmqSubscribe
- DeleteCmqQueue
- CreateCmqTopic
- CreateCmqSubscribe
- CreateCmqQueue
- Other APIs
- Environment Role APIs
- TDMQ for RabbitMQ APIs
- RocketMQ APIs
- DescribeRocketMQVipInstanceDetail
- DescribeRocketMQMsg
- ModifyRocketMQTopic
- ModifyRocketMQNamespace
- ModifyRocketMQGroup
- ModifyRocketMQCluster
- DescribeRocketMQTopics
- DescribeRocketMQNamespaces
- DescribeRocketMQGroups
- DescribeRocketMQClusters
- DescribeRocketMQCluster
- DeleteRocketMQTopic
- DeleteRocketMQGroup
- DeleteRocketMQCluster
- CreateRocketMQTopic
- CreateRocketMQNamespace
- CreateRocketMQGroup
- CreateRocketMQCluster
- TDMQ for RocketMQ APIs
- Production and Consumption APIs
- Data Types
- Error Codes
- SDK Documentation
- FAQs
- TDMQ Policy
- Service Level Agreement
- General References
- Contact Us
- Glossary
- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- Getting Started
- Developer Guide
- Operation Guide
- Practical Tutorial
- API Documentation
- History
- Introduction
- API Category
- Making API Requests
- Message APIs
- Cluster APIs
- Namespace APIs
- Topic APIs
- CMQ Message APIs
- CMQ Management APIs
- UnbindCmqDeadLetter
- RewindCmqQueue
- ModifyCmqTopicAttribute
- ModifyCmqSubscriptionAttribute
- ModifyCmqQueueAttribute
- DescribeCmqTopics
- DescribeCmqTopicDetail
- DescribeCmqSubscriptionDetail
- DescribeCmqQueues
- DescribeCmqQueueDetail
- DeleteCmqTopic
- DeleteCmqSubscribe
- DeleteCmqQueue
- CreateCmqTopic
- CreateCmqSubscribe
- CreateCmqQueue
- Other APIs
- Environment Role APIs
- TDMQ for RabbitMQ APIs
- RocketMQ APIs
- DescribeRocketMQVipInstanceDetail
- DescribeRocketMQMsg
- ModifyRocketMQTopic
- ModifyRocketMQNamespace
- ModifyRocketMQGroup
- ModifyRocketMQCluster
- DescribeRocketMQTopics
- DescribeRocketMQNamespaces
- DescribeRocketMQGroups
- DescribeRocketMQClusters
- DescribeRocketMQCluster
- DeleteRocketMQTopic
- DeleteRocketMQGroup
- DeleteRocketMQCluster
- CreateRocketMQTopic
- CreateRocketMQNamespace
- CreateRocketMQGroup
- CreateRocketMQCluster
- TDMQ for RocketMQ APIs
- Production and Consumption APIs
- Data Types
- Error Codes
- SDK Documentation
- FAQs
- TDMQ Policy
- Service Level Agreement
- General References
- Contact Us
- Glossary
Overview
TDMQ for Apache Pulsar provides the same JWT authentication method used by native Pulsar, which allows you to access TDMQ for Apache Pulsar resources by configuring the token in the client parameters. For directions on how to configure the relationships between different role tokens and TDMQ for Apache Pulsar resources in the console, see Roles and Permissions.
This document describes how to configure JWT authentication in a TDMQ for Apache Pulsar client, so that you can securely use the client to produce and consume messages. You can also add a token when creating a client.
Authentication Configuration
Java client
Configure JWT authentication in a Java client:
PulsarClient client = PulsarClient.builder()// Access address, which can be copied from **Access Address** in the **Operation** column on the **Cluster Management** page.serviceUrl("http://*")// Replace it with the role token displayed on the **Role Management** page.authentication(AuthenticationFactory.token("eyJh****")).build();
PulsarClient client = PulsarClient.builder()// Access address, which can be copied from the access point list in **Cluster Management**.serviceUrl("pulsar://*.*.*.*:6000/")// Replace it with the role token displayed on the **Role Management** page.authentication(AuthenticationFactory.token("eyJh****"))// Replace the value of `custom:` with the route ID in the access point list in **Cluster Management**.listenerName("custom:1********0/vpc-******/subnet-********").build();
Go client
Configure JWT authentication in a Go client:
client, err := NewClient(ClientOptions{// Access address, which can be copied from the access point list in **Cluster Management**URL: "http://*",// Replace it with the role token displayed on the **Role Management** pageAuthentication: NewAuthenticationToken("eyJh****"),})
client, err := NewClient(ClientOptions{// Access address, which can be copied from the access point list in **Cluster Management**URL: "pulsar://*.*.*.*:6000",// Replace it with the role token displayed on the **Role Management** pageAuthentication: NewAuthenticationToken("eyJh****"),// Replace the value of `custom:` with the route ID in the access point list in **Cluster Management**ListenerName: "custom:1300*****0/vpc-******/subnet-********",})
Yes
No
Was this page helpful?