• Change kafka.retrieve_timeseries to expect topic -> route, partition -> job_id