Index: streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java (date 1521596499000) +++ streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java (revision ) @@ -34,4 +34,9 @@ else if (timestamp > otherTimestamp) return 1; return 0; } + + @Override + public boolean equals(Object obj) { + return super.equals(obj); + } } Index: streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java (date 1521596499000) +++ streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java (revision ) @@ -48,4 +48,9 @@ public String toString() { return "Segment(id=" + id + ", name=" + name() + ")"; } + + @Override + public boolean equals(Object obj) { + return super.equals(obj); + } }