Runstreaming job failed with error in bench.log like "org.apache.spark.SparkException: Error getting partition metadata for 'identity'. Does the topic exist?"

[jianblog]

i followed the step:

1. run genSeedDataset.sh
2. run dataGen.sh
   when finished, run run.sh. and got errors. then search the topic in kakfa,only find three topic like this "SPARK_identity_1_5_50_1718960476417
   SPARK_identity_1_5_50_1718960899674
   SPARK_identity_1_5_50_1718961292132”

Is anywhere i missed or got wrong ? anyone know how the streaming testing in right way?