add lost test back
KafkaSplitManager code

This creates per-segment splits for Kafka and sends the splits to the workers.