ming

In partitionConsumer, there is an event loop (eventsCh) handles events asynchronously. However, blocking can still take place because of two reasons in the design. 1. The `eventsCh` is a buffered...

@longtengz Messages flushed by the BatchBuilder's through internalFlushCurrentBatch(). Even if the batch is disabled, the message still needs to be added to a batchBuilder. When batch is disabled, here is...

https://github.com/apache/pulsar-client-go/pull/792 might fix this problem. It guarantees at least one message to be added to a batch that will be sent. [unable to add message to batch] is hard to...

LGTM Go consumer should have an async Ack just like Java API. We should add your code to make the current ack synchronous. Let's do another PR to provide AckAsync()

Added code to use the same ProducerOptions for both DLQ and RLQ. > DLQ and RLQ are created together, and the same data goes first to RLQ and then to...

@wolfstudy @michaeljmarshall Can you help review this PR? @ne1llee is asking when to merge this?

@gavrilyuc2 This is not a bug. Upgrading to linkedin/goavro 2.11 would not fix it. (I tried) In the Avro schema, the gender type is a union. Union in goavro is...

It's addressed by this PR https://github.com/apache/pulsar-client-go/pull/834

At this moment, we only support one pulsar-beam broker. So the broker just reads webhook configuration and pushes messages. Multiple broker is required for capacity and large volume of messages....

There is a new feature in Go 1.8 to detect concurrent edit and access to a map. It's described at https://tip.golang.org/doc/go1.8#mapiter The problem was reported (or panicked) by go map....