milos-matijasevic commented on issue #389: URL: https://github.com/apache/pulsar-client-go/issues/389#issuecomment-727825220
``` INFO[0000] [Connecting to broker] remote_addr="pulsar://localhost:6650" INFO[0000] [TCP connection established] local_addr="127.0.0.1:62626" remote_addr="pulsar://localhost:6650" INFO[0000] [Connection is ready] local_addr="127.0.0.1:62626" remote_addr="pulsar://localhost:6650" INFO[0000] [Connected consumer] consumerID=1 name=ihprt subscription=test-sub topic="persistent://public/default/test" INFO[0000] [Created consumer] consumerID=1 name=ihprt subscription=test-sub topic="persistent://public/default/test" 2443:0:0 2443:1:0 2443:2:0 2443:3:0 INFO[0005] Broker notification of Closed consumer: [1] local_addr="127.0.0.1:62626" remote_addr="pulsar://localhost:6650" INFO[0005] [Reconnecting to broker in 100ms] consumerID=1 name=ihprt subscription=test-sub topic="persistent://public/default/test" INFO[0005] [Error reading from connection] error="Short read when reading frame size: EOF" local_addr="127.0.0.1:62626" remote_addr="pulsar://localhost:6650" INFO[0005] [Connection closed] local_addr="127.0.0.1:62626" remote_addr="pulsar://localhost:6650" 2443:4:0 INFO[0005] [Connecting to broker] remote_addr="pulsar://localhost:6650" WARN[0005] [Failed to connect to broker.] error="dial tcp [::1]:6650: connect: connection refused" remote_addr="pulsar://localhost:6650" INFO[0005] [Connection closed] remote_addr="pulsar://localhost:6650" INFO[0007] [Connecting to broker] remote_addr="pulsar://localhost:6650" WARN[0007] [Failed to connect to broker.] error="dial tcp [::1]:6650: connect: connection refused" remote_addr="pulsar://localhost:6650" INFO[0007] [Connection closed] remote_addr="pulsar://localhost:6650" INFO[0011] [Connecting to broker] remote_addr="pulsar://localhost:6650" WARN[0011] [Failed to connect to broker.] error="dial tcp [::1]:6650: connect: connection refused" remote_addr="pulsar://localhost:6650" INFO[0011] [Connection closed] remote_addr="pulsar://localhost:6650" INFO[0019] [Connecting to broker] remote_addr="pulsar://localhost:6650" WARN[0019] [Failed to connect to broker.] error="dial tcp [::1]:6650: connect: connection refused" remote_addr="pulsar://localhost:6650" INFO[0019] [Connection closed] remote_addr="pulsar://localhost:6650" INFO[0035] [Connecting to broker] remote_addr="pulsar://localhost:6650" INFO[0035] [TCP connection established] local_addr="127.0.0.1:62676" remote_addr="pulsar://localhost:6650" INFO[0035] [Connection is ready] local_addr="127.0.0.1:62676" remote_addr="pulsar://localhost:6650" INFO[0035] [Connected consumer] consumerID=1 name=ihprt subscription=test-sub topic="persistent://public/default/test" INFO[0035] [Reconnected consumer to broker] consumerID=1 name=ihprt subscription=test-sub topic="persistent://public/default/test" 2443:1:0 2443:3:0 2443:4:0 2443:5:0 ^Csignal: interrupt ``` These are logs when this is uncommented,. ```go ReceiverQueueSize: 1, MessageChannel: make(chan pulsar.ConsumerMessage), ``` After reconnecting, the consumer starts to read already read but unacked messages. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
