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 2019/03/18 08:38:34 UTC

[GitHub] [pulsar] se7enkings opened a new issue #3850: The numberOfRecords is always not more than 1 in pulsar-kafka-wrapper-consumer

se7enkings opened a new issue #3850: The numberOfRecords is always not more than 1 in pulsar-kafka-wrapper-consumer
URL: https://github.com/apache/pulsar/issues/3850
 
 
   **Describe the bug**
   - When the loop begin, "++numberOfRecords " is 1, so  "[++numberOfRecords < MAX_RECORDS_IN_SINGLE_POLL](https://github.com/apache/pulsar/blob/da2bb660461345f11446635298c2fdd35955ac32/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java#L357)" is true, which will lead to the loop exit right now. 
   - As a result, the value of numberOfRecords is always not more than 1.
   
   **To Reproduce**
   Steps to reproduce the behavior:
   1. **++numberOfRecords > MAX_RECORDS_IN_SINGLE_POLL**
   
   

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


With regards,
Apache Git Services