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
---
