Moved SystemStreamPartition creation back to SystemConsumer class