private static Map<Integer, String> decodeTopicIndexAndGet(final DataInputStream in) throws IOException {
        final int dictSize = in.readInt();
        final Map<Integer, String> topicIndexDict = new HashMap<>(dictSize);
        for (int i = 0; i < dictSize; i++) {
            topicIndexDict.put(in.readInt(), in.readUTF());
        }
        return topicIndexDict;
    }
@throws TaskAssignmentException if method fails to decode the data or if the data version is unknown
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java