Runstreaming job failed with error in bench.log like "org.apache.spark.SparkException: Error getting partition metadata for 'identity'. Does the topic exist?" #744
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?
i followed the step:
Is anywhere i missed or got wrong ? anyone know how the streaming testing in right way?