You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/04/12 08:03:42 UTC

[GitHub] [pulsar-client-go] jonyhy96 opened a new issue #508: KeyBasedBatchBuilder always timeout

jonyhy96 opened a new issue #508:
URL: https://github.com/apache/pulsar-client-go/issues/508


   #### Expected behavior
   
   internalFlushCurrentBatches behave normally like internalFlushCurrentBatch
   
   #### Actual behavior
   
   internalFlushCurrentBatches always timeout
   
   #### Steps to reproduce
   
   Use KeyBasedBatchBuilder to produce message and wait for a while, timeout will happens in `failTimeoutMessages` because of less of sentAt set at [here](https://github.com/apache/pulsar-client-go/blob/master/pulsar/producer_partition.go#L549). Should add sentAt like [this](https://github.com/apache/pulsar-client-go/blob/master/pulsar/producer_partition.go#L442)
   
   #### System configuration
   **Pulsar version**: any
   


-- 
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:
users@infra.apache.org

[GitHub] [pulsar-client-go] wolfstudy closed issue #508: KeyBasedBatchBuilder always timeout

Posted by GitBox <gi...@apache.org>.

wolfstudy closed issue #508:
URL: https://github.com/apache/pulsar-client-go/issues/508


   


-- 
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:
users@infra.apache.org