|
@@ -67,7 +67,7 @@ public class PulsarClientService {
|
|
if (consumerConn) {
|
|
if (consumerConn) {
|
|
consumer = client.newConsumer()
|
|
consumer = client.newConsumer()
|
|
.topic(topics.split(","))//topic完整路径,格式为persistent://集群(租户)ID/命名空间/Topic名称
|
|
.topic(topics.split(","))//topic完整路径,格式为persistent://集群(租户)ID/命名空间/Topic名称
|
|
- .subscriptionName("ygp")//需要现在控制台或者通过控制台API创建好一个订阅,此处填写订阅名
|
|
|
|
|
|
+ .subscriptionName("mp")//需要现在控制台或者通过控制台API创建好一个订阅,此处填写订阅名
|
|
.subscriptionType(SubscriptionType.Exclusive)//声明消费模式为exclusive(独占)模式
|
|
.subscriptionType(SubscriptionType.Exclusive)//声明消费模式为exclusive(独占)模式
|
|
.subscriptionInitialPosition(
|
|
.subscriptionInitialPosition(
|
|
SubscriptionInitialPosition.Earliest)//配置从最早开始消费,否则可能会消费不到历史消息
|
|
SubscriptionInitialPosition.Earliest)//配置从最早开始消费,否则可能会消费不到历史消息
|