fix argument name for kafka topic

5 jobs for master in 14 minutes and 40 seconds (queued for 2 seconds)