allow remote_trainer.py to start from the end of kafka pipe.