0

想用spark分析zipkin输出的数据,结果第一步就出现困难... =。=

在kafka中有Span类型的数据,格式是Bytes[],需要通过SpanBytesDecoder这么一个类转换成Span类型,我这么在Spark Structured Streaming处理,成DataSet<Span>或者DataFrame

val df = spark.readStream
      .format("kafka")
      .option("kafka.bootstrap.servers", "node1:9092, node2:9092, node3:9092")
      .option("subscribe", "zipkin")
      .option("group.id", "my-group-id")
      .load()
2019-07-04 提问
0 个回答

撰写答案

推广链接