pulsar Error receiving messages.Consumer already closed at
报错内容
[ 2025-09-17 23:51:50.666 ] [ ERROR ] [ org.springframework.Pulsar.PulsarListenerEndpointContainer#1-0-C-3 ] [ o.s.p.l.DefaultPulsarMessageListenerContainer : 261 ] Error receiving messages.
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: Consumer already closed
at org.apache.pulsar.client.impl.ConsumerBase.verifyConsumerState(ConsumerBase.java:943)
at org.apache.pulsar.client.impl.ConsumerBase.batchReceive(ConsumerBase.java:299)
at org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer$Listener.run(DefaultPulsarMessageListenerContainer.java:479)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:842)
版本
报错类
处理方法,将long改成Long,原因未知