pulsar-client-go

pulsar-client-go copied to clipboard

Resend after reconnection cause reproduce of the same msg

1

https://github.com/apache/pulsar-client-go/blob/965045aa0d2c077826f64d0b88a5d5e55d9d50c4/pulsar/producer_partition.go#L272 After the reconnection of the producer, the msg in the pendingQueue will be resend. But not every msg in pendingQueue hasn't send to broker, the resend logic here seems...

WinChua

Signed-off-by: xiaolongran ### Motivation When producer send message or consumer receive message in non-batch, return the batchIdx is `0` ``` msgId: pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:11653378, entryID:3807, batchIdx:0, partitionIdx:2} ``` In fact, when we...

wolfstudy

**Is your feature request related to a problem? Please describe.** No **Describe the solution you'd like** Add method PhysicalAddr() to interface [Producer](https://github.com/apache/pulsar-client-go/blob/master/pulsar/producer.go#L174) and interface [Consumer](https://github.com/apache/pulsar-client-go/blob/master/pulsar/consumer.go#L188) which exposes the broker address...

WinChua

ReceiverQueueSize of 0 doesn't work as intended

6

(This was already reported against the old driver here (by me): https://github.com/apache/pulsar/issues/6496 but it was noted this was fixed with the new go implementation, which doesn't seem the case. The...

wonko

Consumer can't receive messag after broker has been restarted

4

#### Expected behavior creating a consumer firstly, then restart pulsar broker, consumer will reconnect the broker. After successful reconnection, Consumers should receive message normally. #### Actual behavior After successful reconnection,...

xige-16

Release oauth2 with new Tags

2

The `oauth2` is a sub module for pulsar-client-go. We need to release it with a separate Tag like `oauth2/v1.0.0`.

syhily

Add LastSequenceID interface for consumer

3

**Is your feature request related to a problem? Please describe.** consumer don't provide the LastSequenceID interface to get the topic's last messageID **Describe the solution you'd like** **Describe alternatives you've...

xige-16

Add Support for NonDurable subscriptions

11

**Is your feature request related to a problem? Please describe.** The Java API supports Non-Durable Subscriptions via SubscriptionMode https://github.com/apache/pulsar/blob/master/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java#L243-L256 but it appears that the Go client does not https://github.com/apache/pulsar-client-go/blob/25f3075176f853f5f09d89b3b625e0646432735f/pulsar/consumer.go#L76 This...

frankjkelly

consume stuck after seekByTiime

4

#### Expected behavior consume success after seekByTime #### Actual behavior After running the for loop a few times, step msg :=

xige-16

[Go schema] Support multi version schema for repo

1

Currently, we already support a single topic schema in producer and consumer for Go client. The following are other functions of the schema that need to be supported: - [...

wolfstudy