gt;
>
>
> *Regards,*
>
> *Favas *
>
>
>
> *From:* Muhammed Favas
> *Sent:* Thursday, June 10, 2021 15:26 PM
> *To:* user@spark.apache.org
> *Subject:* Apply window function on data consumed from Kafka topic
>
>
>
> Hi,
>
>
>
>
Hi All,
Can some one help me how to resolve this?. It is very important to achieve my
project objective
Regards,
Favas
From: Muhammed Favas
Sent: Thursday, June 10, 2021 15:26 PM
To: user@spark.apache.org
Subject: Apply window function on data consumed from Kafka topic
Hi,
I
Hi,
I have a requirement to create a spark streaming job that get
data from kafka broker and need to apply window function on the data coming
into the spark context.
This is how I connected to kafka from spark
val kafkaParams = Map[String, Object](
"bootstrap.servers" -> "",
