@Override
    public boolean equals(final Object o) {
        if (o instanceof SubscriptionInfo) {
            final SubscriptionInfo other = (SubscriptionInfo) o;
            return data.equals(other.data);
        } else {
            return false;
        }
    }
@throws TaskAssignmentException if method fails to decode the data
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java