[
https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16324857#comment-16324857
]
Ivan Babrou commented on KAFKA-6441:
Looks like the issue is in Sarama, which only reads one record
[
https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323603#comment-16323603
]
Ivan Babrou commented on KAFKA-6441:
I dumped raw bytes from Kafka responses and it seems like buffers
[
https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323073#comment-16323073
]
Ivan Babrou commented on KAFKA-6441:
I think it's a bit different, buffers for each partition are
[
https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321715#comment-16321715
]
Ivan Babrou commented on KAFKA-6441:
With 0.10.2.0 consumer API Sarama is able to get multiple
[
https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321716#comment-16321716
]
Ivan Babrou commented on KAFKA-6441:
With 0.10.2.0 consumer API Sarama is able to get multiple