private static Map<HostInfo, Set<TopicPartition>> decodeHostPartitionMapUsingDictionary(final DataInputStream in,
                                                                                            final Map<Integer, String> topicIndexDict) throws IOException {
        final Map<HostInfo, Set<TopicPartition>> hostPartitionMap = new HashMap<>();
        final int numEntries = in.readInt();
        for (int i = 0; i < numEntries; i++) {
            final HostInfo hostInfo = new HostInfo(in.readUTF(), in.readInt());
            hostPartitionMap.put(hostInfo, readTopicPartitions(in, topicIndexDict));
        }
        return hostPartitionMap;
    }
@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