@Override
    public TaskWorker newTaskWorker(String id) {
        return new RoundTripWorker(id, this);
    }
The specification for a workload that sends messages to a broker and then
reads them back.
trogdor/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java