protected Map<String, Collection<Integer>> asMap() {
            // Using LinkedHashMap preserves the ordering, which is helpful for tests and debugging
            Map<String, Collection<Integer>> taskMap = new LinkedHashMap<>();
            for (String connectorId : new HashSet<>(connectorIds)) {
                taskMap.computeIfAbsent(connectorId, key -> new ArrayList<>()).add(CONNECTOR_TASK);
            }
            for (ConnectorTaskId taskId : taskIds) {
                String connectorId = taskId.connector();
                taskMap.computeIfAbsent(connectorId, key -> new ArrayList<>()).add(taskId.task());
            }
            return taskMap;
        }
The tasks included in this assignment.

@return the tasks
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java