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

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/STORM-424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074263#comment-14074263 ] 

ASF GitHub Bot commented on STORM-424:
--------------------------------------

Github user fxjwind commented on the pull request:

    https://github.com/apache/incubator-storm/pull/200#issuecomment-50132196
  
    @kishorvpatil  Done


> 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
>   Original Estimate: 1h
>  Remaining Estimate: 1h
>
>  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)