[STORM-424] Issue on KafkaOffsetMetric(external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java)

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.9.2-incubating
• Fix Version/s: 0.9.3
• Component/s: storm-kafka
• Assignee: Unassigned
• Reporter: feng xiaojie
• Created: 25/Jul/14 10:13
• Updated: 26/Sep/15 02:41
• Resolved: 29/Aug/14 17:12

Description

if (latestTimeOffset == 0 || earliestTimeOffset == 0) {
LOG.warn("No data found in Kafka Partition " + partition.getId());
return null;
}
The earliestTimeOffset is 0 by default for a partition, and only after log.retention(segment be deleted), earliestTimeOffset will larger than 0.
So you will always see the warning, if you run storm-kafka on a new patition, even if there are much data in your partition