pulsar-client-go

pulsar-client-go copied to clipboard

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when [...] **Describe the solution you'd...

carrotshub

v0.3.1 use host: pulsar://10.57.98.208:6650,10.57.98.209:6650,10.57.98.210:6650, happend WARN[2510] [Failed to connect to broker.] error="dial tcp: address 192.168.33.3:6650,192.168.33.4:6650,192.168.33.5:6650: too many colons in address" remote_addr="pulsar://192.168.33.3:6650,192.168.33.4:6650,192.168.33.5:6650"

sixhj

Update package to use go.mod

1

Blquinn

Add ManagedConsumer timeoutAck and RedeliverUnacknowledged support plz

1

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when [...] **Describe the solution you'd...

leenux

after ManagedConsumer.Close(), ManagedConsumer.manage() will receive

JaydenHan1106

#### Expected behavior When using a managed consumer with QueueSize == 1, eg ``` c := pulsar.ManagedConsumerConfig{ QueueSize: 1, } ``` Then it's expected that `c.ReceiveAsync` receive messages. #### Actual...

awilliams

whatever I use consumerManager or consumer, both I can't position the message to a specified cursor. This is nessary for my function.

mazhan465