billowqiu

AckID block calling goroutine

1

#### Expected behavior partitionConsumer.AckID should not block calling goroutine. #### Actual behavior block calling goroutine infinite  #### Steps to reproduce call Consumer AckID(MessageID) method. ``` func (pc *partitionConsumer) AckID(msgID...

[bugfix] fix stuck when ProducerBlockedQuotaExceededException

1

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #768 ### Motivation - fix stuck when ProducerBlockedQuotaExceededException ### Modifications - store the error when partitionProducer.grabCnx - fail...

[bugfix] fix stuck when ProducerBlockedQuotaExceededException

2

#### Expected behavior fail fast when user call Send #### Actual behavior stuck in Send method #### Steps to reproduce 1：set a 10MB backlog in pulsar topic 2：Infinite loop call...

#### Expected behavior when consumer or producer Closed， should call Registerer.Unregister to remove unuse metrics in memory #### Actual behavior when consumer or producer Closed, the metrics object still in...

any plan to support in multi thread?

17

like this link [Passing Segment Context between Threads in a Multithreaded Application](https://docs.aws.amazon.com/xray/latest/devguide/xray-sdk-java-multithreading.html)

Any plan to support jaeger exporter?

1

Jaeger is a good opentracing impl, have plan to support jaeger exporter？

Fixes #850 *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)* Master Issue: # ### Motivation *Explain...

Ack/Nack use closed consumer

1

#### Expected behavior 1：use Client to Subscribe a topic create an consumer-1 2：Receive message use consumer-1 3：then in some case consumer-1 is Closed. 4：use the same Client to create another...