时光留夏: 请教下，这种类型的消费者能关闭吗，如何优雅的关闭，不报异常？ 2023-12-15 10:08:54.257 ERROR [pulsar-client-internal-14-1] [TID: N/A] :Receive operation failed on consumer ConsumerBase{subscription='realtimeCurvesNew_192.168.51.0', consumerName='23798', topic='persistent://standarddata/seismic/HN_CDE01'} - Retrying later : $AlreadyClosedException: The consumer which subscribes the topic persistent://standarddata/seismic/HN_CDE01 with subscription name realtimeCurvesNew_192.168.51.0 was already closed when cleaning and closing the consumers at (:292) at (:308) at (:647) at $$$$capture(:632) at
Pulsar源码解析
Pulsar源码解析-客户端-多消费者MultiTopicsConsumerImpl创建底层实现