[
https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15012497#comment-15012497
]
Guozhang Wang commented on KAFKA-2843:
--------------------------------------
Is there a leader failover round the same time for that partition? There is a
potential issue described in KAFKA-2334 but is only possible if a leader
failover happens.
> when consumer got empty messageset, fetchResponse.highWatermark !=
> current_offset?
> ----------------------------------------------------------------------------------
>
> Key: KAFKA-2843
> URL: https://issues.apache.org/jira/browse/KAFKA-2843
> Project: Kafka
> Issue Type: Bug
> Components: offset manager
> Affects Versions: 0.8.2.1
> Reporter: netcafe
> Assignee: jin xing
>
> I use simple consumer fetch message from brokers (fetchSize >
> messageSize)，when consumer got empty messageSet，e.g ：
> val offset = nextOffset
> val request = buildRequest(offset)
> val response = consumer.fetch(request)
> val msgSet = fetchResponse.messageSet(topic, partition)
>
> if (msgSet.isEmpty) {
> val hwOffset = fetchResponse.highWatermark(topic, partition)
>
> if (offset == hwOffset) {
> // ok, doSomething...
> } else {
> // in our scene, i found highWatermark may not equals current offset
> ，but we did not reproduced it.
> // Is this case could happen ? if could, why ?
> }
> }
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
