有一些基本问题，希望有人能解决。
所以我想在我的应用程序中使用apachekafka和apachespark。我已经通过了大量的教程，得到了它是什么和它将如何工作的基本想法。
用例：
数据将以40秒的间隔从一个移动设备（多个设备，比方说1000个）生成，我需要处理这些数据并向数据库添加值，这些值反过来会反映在 Jmeter 板中。
我想做的是使用apache streams并从android本身发出post请求，然后这些数据将由spark应用程序处理，就这样。
问题：
ApacheSpark
我遵循本教程来启动并运行它。（我使用的是java，而不是scala）链接：https://www.santoshsrinivas.com/installing-apache-spark-on-ubuntu-16-04/
完成所有操作后，我执行sparkshell并启动它。我也在我的服务器上安装了zookeeper和kafka，我在后台启动了kafka，所以这不是问题。
当我跑的时候 http://161...:4040/jobs/ 我得到这一页

在我阅读的所有教程中，都有这样一页：https://i.stack.imgur.com/gf1fn.png 但我不明白。是不是Spark没有安装好？
现在，当我想部署一个独立的jar到spark时，（使用以下链接：http://data-scientist-in-training.blogspot.in/2015/03/apache-spark-cluster-deployment-part-1.html )我可以运行它。i、 使用以下命令： spark-submit --class SimpleApp.SimpleApp --master spark://http://161...:7077 --name "try" /opt/spark/bin/try-0.0.1-SNAPSHOT.jar ，我得到输出。
如果我想使用它，我需要每次提交申请吗？
这是我的程序：

package SimpleApp;

/* SimpleApp.java */
import org.apache.spark.api.java.*;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.function.Function;

public class SimpleApp {
  public static void main(String[] args) {
    String logFile = "/opt/spark/README.md"; // Should be some file on your system
    SparkConf conf = new SparkConf().setAppName("Simple Application").setMaster("local[*]");
    JavaSparkContext sc = new JavaSparkContext(conf);
    //System.setProperty("hadoop.home.dir", "C:/winutil");
    sc.setLogLevel("ERROR"); // Don't want the INFO stuff
    JavaRDD<String> logData = sc.textFile(logFile).cache();

    long numAs = logData.filter(new Function<String, Boolean>() {
      public Boolean call(String s) { return s.contains("a"); }
    }).count();

    long numBs = logData.filter(new Function<String, Boolean>() {
      public Boolean call(String s) { return s.contains("b"); }
    }).count();

    System.out.println("Lines with a: " + numAs + ", lines with b: " + numBs);
    System.out.println("word count : "+logData.first());
    sc.stop();
  }
}

现在我该如何将Kafka融入其中？
如何将应用程序配置为每次Kafka收到消息时都执行它？
此外，我是否需要制作一个restapi，通过它我需要将数据发送到kafka，即restapi将被用作生产者？类似spark java框架的东西？http://sparkjava.com/
如果是，瓶颈将再次发生在restapi级别，即它可以处理多少请求，因为我读到的kafka到处都有很高的吞吐量。
最终的结构会像SparkJava->kafka->ApacheSpark一样吗？
最后，如何在本地设备上设置开发结构？我已经安装了kafka/apache spark。我正在使用eclipse。
谢谢