[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15028229#comment-15028229 ] netcafe commented on KAFKA-2843: I did, no result. > when consumer got empty messageset,

[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15013639#comment-15013639 ] netcafe commented on KAFKA-2843: I grep -i 'deleted brokers' *.log on all 3 kafka brokers

[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15009307#comment-15009307 ] netcafe commented on KAFKA-2843: This topic only one partition. > when consumer got emp

[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008112#comment-15008112 ] netcafe commented on KAFKA-2843: yes, before parse fetchResponse，I had checked response.h

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers (fetchSize > messageSize)，when consumer got emp

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v