Migration Changes

The default distributor was assuming one line of output per call to consume(). Now custom consumers that write variable numbers of lines can now tell the distributor how many lines they wrote.