tdmq-pulsar-java-demo

Message Producer, Consumer and Tag Filter

Configuration

Pulsar Configuration:

  public static final String SERVICE_URL = "http://pulsar-xxxx.tdmq.ap-gz.qcloud.tencenttdmq.com:5035";
  public static final String USER_TOKEN = "....use....token...";
  public static final String TOPIC_ADDRESS = "persistent://pulsar-xxx/default/chat";

Compile

mvn package

Run

mvn run

More information

• TDMQ
• TDMQ Doc