public static KafkaStreamsAssignment of(final ProcessId processId, final Set<AssignedTask> assignment) {
        final Map<TaskId, AssignedTask> tasks = assignment.stream().collect(Collectors.toMap(AssignedTask::id, Function.identity()));
        return new KafkaStreamsAssignment(processId, tasks, Optional.empty());
    }
Construct an instance of KafkaStreamsAssignment with this processId and the given set of
assigned tasks. If you want this KafkaStreams client to request a followup rebalance, you
can set the followupRebalanceDeadline via the {@link #withFollowupRebalance(Instant)} API.

@param processId the processId for the KafkaStreams client that should receive this assignment
@param assignment the set of tasks to be assigned to this KafkaStreams client

@return a new KafkaStreamsAssignment object with the given processId and assignment
streams/src/main/java/org/apache/kafka/streams/processor/assignment/KafkaStreamsAssignment.java