@Override
    public TaskWorker newTaskWorker(String id) {
        return new NetworkPartitionFaultWorker(id, partitionSets());
    }
The specification for a fault that creates a network partition.
trogdor/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java