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 2020/07/27 05:28:29 UTC

[GitHub] [pulsar] equanz edited a comment on pull request #7553: [pulsar-broker] Stop to dispatch when skip message temporally since Key_Shared consumer stuck on delivery

equanz edited a comment on pull request #7553:
URL: https://github.com/apache/pulsar/pull/7553#issuecomment-664125696


   @feeblefakie Thank you for your check. But I couldn't reproduce your issue (my procedure below) now. Is [this debug log](https://github.com/apache/pulsar/pull/7553/files#diff-8f773b51748a5cb5f7a298a4f65d1134R264) occurred in your standalone? Or please tell me more detail.
   
   test procedure
   1. build this code
   2. start standalone with `--wipe-data` and default config (so, use `AUTO_SPLIT`)
   3. create partitioned topic with 32 partition
   4. create subscription `sub0`, and `sub1` as latest position to same topic
   5. produce messages with your [code](https://github.com/feeblefakie/misc/blob/ed6439c596227eace6ce7176d93424fa35d34406/pulsar/src/main/java/MyProducer.java)
   6. consume messages as `sub0` by your [code](https://github.com/feeblefakie/misc/blob/ed6439c596227eace6ce7176d93424fa35d34406/pulsar/src/main/java/MyConsumer.java)
      - out: 10000 records
   7. consume messages as `sub1` by your [code](https://github.com/feeblefakie/misc/blob/ed6439c596227eace6ce7176d93424fa35d34406/pulsar/src/main/java/MyConsumer.java)
      - out: 10000 records
   8. check output by your [script](https://github.com/feeblefakie/misc/blob/ed6439c596227eace6ce7176d93424fa35d34406/pulsar/check.sh)
   
   and no `NG` was found(with 1000 `OK`).


----------------------------------------------------------------
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