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
için Bir jips uygulamasında jvectormap kullanmaya çalışıyorum ve başlamak için jvectormap web sitesindeki örnekleri takip ediyorum. Ancak, "jvm.Map bir kurucu değil" hatasını neden aldığımı anlayamıyo
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