bpereto opened a new issue, #24018: URL: https://github.com/apache/pulsar/issues/24018
### Search before asking - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker. ### Version Linux, JDK 17 Broker: 3.0.5 Client: image: streamnative/pulsar-io-jdbc-clickhouse:4.0.1.3 ### Minimal reproduce step Currently not known how to reproduce. ### What did you expect to see? All messages from the non-persistent partioned topics are sinked into a clickhouse database. ### What did you see instead? After some time of a working sink (hours to days), presumably after a network error, the consumer reconnects to the broker and no further messages are processed. ``` 2025-02-24T13:07:54,380+0100 [pulsar-io-4-1] WARN org.apache.pulsar.broker.service.ServerCnx - [/86.119.37.116:37398] Got exception io.netty.channel.unix.Errors$NativeIoException: recvAddress(..) failed: Connection reset by peer 2025-02-24T13:07:54,380+0100 [pulsar-io-4-8] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /86.119.x.x:37390 2025-02-24T13:07:54,380+0100 [pulsar-io-4-1] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /86.119.x.x:37398 2025-02-24T13:07:54,380+0100 [pulsar-io-4-1] INFO org.apache.pulsar.broker.service.nonpersistent.NonPersistentDispatcherMultipleConsumers - Removed consumer Consumer{subscription=NonPersistentSubscription{topic=non-persistent://net/flow/goflow.v2-partition-5, name=c/c/sink}, consumerId=5, consumerName=zXnBW, address=[id: 0x29446605, L:/10.0.0.27:6651 ! R:/86.119.x.x:37398] [SR:86.119.x.x, state:Failed]} 2025-02-24T13:08:00,539+0100 [pulsar-io-4-6] INFO org.apache.pulsar.broker.service.ServerCnx - [/86.119.x.x:45206] connected with role=c using authMethod=token, clientVersion=Pulsar-Java-v4.0.1.3, clientProtocolVersion=21, proxyVersion=null 2025-02-24T13:08:00,566+0100 [pulsar-io-4-6] INFO org.apache.pulsar.broker.service.ServerCnx - [[id: 0x11556fae, L:/10.0.0.27:6651 - R:/86.119.x.x:45206] [SR:86.119.x.x, state:Connected]] Subscribing on topic non-persistent://net/flow/goflow.v2-partition-5 / c/c/sink. consumerId: 5 2025-02-24T13:08:00,580+0100 [configuration-metadata-store-13-1] INFO org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic - [non-persistent://net/flow/goflow.v2-partition-5][c/c/sink] Created new subscription for 5 2025-02-24T13:08:00,580+0100 [configuration-metadata-store-13-1] INFO org.apache.pulsar.broker.service.ServerCnx - [/86.119.x.x:45206] Created subscription on topic non-persistent://net/flow/goflow.v2-partition-5 / c/c/sink ``` ### Anything else? _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
