Ben bu basit Kafka Akış Kafka iletiler val messages = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParams, topicsSet)
// Each Kafka message is a flight
val
Bir DStream'i bir diziye, listeye vb. Dönüştürmek istiyorum, böylece onu json'a çevirip bir uç noktaya sunabiliyorum. Twitter verilerini enjekte ederek apache kıvılcımı kullanıyorum. Bu işlemi Dstream