Pulsar   https://pulsar.apache.org/docs/3.0.x/

wget https://archive.apache.org/dist/pulsar/pulsar-3.0.1/apache-pulsar-3.0.1-bin.tar.gz

tar -zxvf apache-pulsar-3.0.1-bin.tar.gz  

bin/pulsar-admin  topics create  topicCCC

bin/pulsar-admin  topics create  persistent://public/default/topicCCC

bin/pulsar-admin tenants create custormerAAA

bin/pulsar-admin tenants list 

bin/pulsar-admin namespaces create custormerAAA/prjBBB

bin/pulsar-admin namespaces list custormerAAA

bin/pulsar-admin  topics create non-persistent://custormerAAA/prjBBB/topicCCC

 bin/pulsar-client   produce non-persistent://custormerAAA/prjBBB/topicCCC --messages 'Hello Pulsar!2222222222' 

bin/pulsar-client   consume non-persistent://custormerAAA/prjBBB/topicCCC -s PC001 -p Earliest -n 0

  

         <dependency>

            <groupId>io.quarkus</groupId>

            <artifactId>quarkus-smallrye-reactive-messaging-pulsar</artifactId>

        </dependency>

 

     

        <dependency>

            <groupId>org.conscrypt</groupId>

            <artifactId>conscrypt-openjdk-uber</artifactId>

            <version>2.5.2</version>

        </dependency>

 

 @RegisterForReflection

     @BuildStep

    @Produce(JPMSExportBuildItem.class)

    JPMSExportBuildItem exportBuildItem7() {

        return new JPMSExportBuildItem("java.base", "sun.net");

} 

 quarkus.reactive-messaging.auto-connector-attachment=false mp.messaging.outgoing.channelA.connector=smallrye-pulsar

mp.messaging.outgoing.channelB.connector=smallrye-pulsar

mp.messaging.outgoing.channelA.serviceUrl=${MQ_PULSAR_URL:pulsar://localhost:6650}

mp.messaging.outgoing.channelB.serviceUrl=${MQ_PULSAR_URL:pulsar://localhost:6650} 

mp.messaging.outgoing.channelA.topic=${MQ_CHANNELA_TOPIC:topicA}

mp.messaging.outgoing.channelB.topic=${MQ_CHANNELB_TOPIC:topicB}