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

[wanghongjiang (JIRA)]

wanghongjiang created KAFKA-2843:
------------------------------------

             Summary: 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: wanghongjiang


I use simple consumer fetch message from brokers，when consumer got empty 
messageSet，e.g ：

    val offset = lastOffset
    val msgSet = fetchResponse.messageSet(topic, partition)

    if (msgSet.isEmpty) {
      val hwOffset = fetchResponse.highWatermark(cli.kafkaTopic, 
cli.kafkaPartition)
      
      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)