Github user hmcl commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2538#discussion_r165857469
  
    --- Diff: 
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommitMetadataManager.java
 ---
    @@ -75,8 +75,9 @@ public boolean 
isOffsetCommittedByThisTopology(TopicPartition tp, OffsetAndMetad
                 final CommitMetadata committedMetadata = 
JSON_MAPPER.readValue(committedOffset.metadata(), CommitMetadata.class);
                 return 
committedMetadata.getTopologyId().equals(context.getStormId());
             } catch (IOException e) {
    -            LOG.warn("Failed to deserialize [{}]. Error likely occurred 
because the last commit "
    -                + "for this topic-partition was done using an earlier 
version of Storm. "
    +            LOG.warn("Failed to deserialize expected commit metadata [{}]."
    +                + " This error is expected to occur once per partition, if 
the last commit to each partition"
    +                + " was by an earlier version of the KafkaSpout, or by 
something other than the KafkaSpout. "
    --- End diff --
    
    was done by an earlier version ... or by a process other than the KafkaSpout
    



---

Reply via email to