feng xiaojie created STORM-424:
----------------------------------
Summary: Issue on
KafkaOffsetMetric(external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java)
Key: STORM-424
URL: https://issues.apache.org/jira/browse/STORM-424
Project: Apache Storm (Incubating)
Issue Type: Bug
Affects Versions: 0.9.2-incubating
Reporter: feng xiaojie
Priority: Minor
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
--
This message was sent by Atlassian JIRA
(v6.2#6252)
