@Override
    public boolean equals(final Object o) {
        if (o instanceof LegacySubscriptionInfoSerde) {
            final LegacySubscriptionInfoSerde other = (LegacySubscriptionInfoSerde) o;
            return usedVersion == other.usedVersion &&
                latestSupportedVersion == other.latestSupportedVersion &&
                processId.equals(other.processId) &&
                prevTasks.equals(other.prevTasks) &&
                standbyTasks.equals(other.standbyTasks) &&
                userEndPoint != null ? userEndPoint.equals(other.userEndPoint) : other.userEndPoint == null;
        } else {
            return false;
        }
    }
@throws TaskAssignmentException if method fails to decode the data
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java