Then the old connection starts to be disconnected, and the producer status of the server on the connection is cleared Remove the producer in ServerCnx from the pulsar server,, this PR modified the equals method of the Producer, resulting in the inability to remove the producer from the topic's prodcuers map. This addition operation comes from the same ip of the client, a different port connection, and the producerName is equal to the previous one In the case that the previous connection has not been disconnected, the client sends an add producer operation for the same producerName The following log progresses according to the timeline:ДЇirst, there is an active channel and producer that is writing data to the broker When reconnecting to the server, the old connection is not closed. When reconnecting to the server, the old connection should be closed. Possibly related issue: System configuration It looks like even if DisableBatching is set to true, it still uses a batchBuilder to build a batch, and that batchBuilder respects all the other batching related configs. use go client to produce avro messages with DisableBatching=true or DisableBatching=false.Pulsar-client consume -st auto_consume -s test topic_name -n 0 I expect, whether batching enabled or not, I can always get avro typed messages. I'm not sure how batching has anything to do with AUTO_CONSUME's way of inferring schema type. When batching is disabled, I get avro typed message. When using python, and batching is enabled, I get the above string typed message. This is inconsistent with the python client. This is with or without DisableBatching enabled. When using go client to produce messages with avro schema, and consume using

Licensed under the Apache License, Version 2.0: See CONTRIBUTING.md for details on submitting patches and the contribution workflow. UsageД¬ontributions are welcomed and greatly appreciated. Once feature parity and stability are reached, this will supersede the current This projects is developing a pure-Go client library for Pulsar that does not A Go client library for the Apache Pulsar project.

Ruby slack client reconnect