tencent cloud

<dependency>
    <groupId>io.github.majusko</groupId>
    <artifactId>pulsar-java-spring-boot-starter</artifactId>
    <version>1.0.7</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.projectreactor/reactor-core -->
<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-core</artifactId>
    <version>3.4.11</version>
</dependency>


pulsar:
  # Namespace name
  namespace: namespace_java
  # Service access address
  service-url: http://pulsar-xxx.tdmq.ap-gz.public.tencenttdmq.com:8080
  # Role token
  token-auth-value: eyJrZXlJZC....
  # Cluster name
  tenant: pulsar-xxx


@PulsarConsumer(topic = "topic1",  // Name of the subscribed topic
                subscriptionName = "sub_topic1", // Subscription name
                serialization = Serialization.JSON, // Serialization method
                subscriptionType = SubscriptionType.Shared, // Subscription mode, which is exclusive mode by default
                consumerName = "firstTopicConsumer", // Consumer name
                maxRedeliverCount = 3, // Maximum number of retries
                deadLetterTopic = "sub_topic1-DLQ" // Dead letter topic name
               )
public void topicConsume(byte[] msg) {
    // TODO process your message
    System.out.println("Received a new message. content: [" + new String(msg) + "]");
    // If the consumption fails, throw an exception, so that the message will enter the retry letter topic and can be consumed again. Once the maximum number of retries is reached, the message will enter the dead letter topic. You need to create retry and dead letter queues for the above process
}