private static ProcessId decodeProcessId(final ByteBuffer data) {
        return new ProcessId(new UUID(data.getLong(), data.getLong()));
    }
@throws TaskAssignmentException if method fails to decode the data
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java