PulsarMQ对接指南

注意

仅支持本地K8S版本

本文介绍如何使用Java SDK,完成对领域事件的PulsarMQ消息接收。

步骤一: 准备工作

1.下载Java SDK。

2.创建Maven工程，将SDK文件添加为依赖项导入Project Library,并且引入Pulsar的客户端依赖，pom.xml配置如下:

        <dependency>
            <groupId>org.apache.pulsar</groupId>
            <artifactId>pulsar-client-all</artifactId>
            <version>2.10.2</version>
        </dependency>

3.在AIoT平台创建属于您的访问凭证,并获取对应的AccessKeyId和AccessKeySecret。

提示

JAVA SDK版本说明:

Version:1.0.0

更新日期:
2024-06-25

Java SDK下载

使用说明:
请使用JDK11及以上版本，否则可能会出现JDK版本兼容问题

步骤二: 接收消息

关于更多客户端的使用可以参考Pulsar官网的使用。

PulsarMQ对接指南

步骤一: 准备工作#

Version:1.0.0#

步骤二: 接收消息#

步骤一: 准备工作

Version:1.0.0

步骤二: 接收消息