Я пытаюсь соединить kafka с python (блокнотом jupyter) после добавления jar-файла, мой код не запускается и выдает ошибку. Можете ли вы сказать мне, как я могу подключить kafka с любым из Python IDE, таким как pycharm и jupyter notebook
Я попытался запустить его в блокноте Jupter, это просто программа для подсчета слов, а данные не поступают в блокнот Jupyter. Затем я попытался передать скрипт Python с командной строкой, но он показывает некоторую ошибку
bin / spark-submit --jars --master spark: // Ubuntu: 7077 /home/user/spark-2.4.3-bin-hadoop2.7/jars/spark-streaming-kafka-0-8-assembly_2.11-2.4.3.jar
Исключение в потоке "main" org.apache.spark.SparkException: Невозможно загрузить основной класс из JAR spark: // Ubuntu: 7077 с URI-искрой.Пожалуйста, укажите класс через --class.в org.apache.spark.deploy.SparkSubmitArguments.error (SparkSubmitArguments.scala: 657) в org.apache.spark.deploy.SparkSubmitArguments.loadEnvironmentArguments (SparkSubmitArguments.scala: 224) в org.pache.pache.pache. sp.SparkSubmitArguments.scala: 116) в org.apache.spark.deploy.SparkSubmit $$ anon $ 2 $$ anon $ 1. (SparkSubmit.scala: 911) в org.apache.spark.deploy.SparkSubmit $$ anon $ 2.parseArguments (SparkSubmit.scala: 911) в org.apache.spark.deploy.SparkSubmit.doSubmit (SparkSubmit.scala: 81) в org.apache.spark.deploy.SparkSubmit $$ anon $ 2.doSubmit (SparkSubmit.scala: 924) в орг.apache.spark.deploy.SparkSubmit $ .main (SparkSubmit.scala: 933) в org.apache.spark.deploy.SparkSubmit.main (SparkSubmit.scala)