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)
