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}
全部评论