tom to Kafka.
>
> Boyang
>
> On Wed, Mar 4, 2020 at 7:37 AM Something Something <
> mailinglist...@gmail.com>
> wrote:
>
> > Need help integrating Kafka with 'Stateful Spark Streaming' application.
> >
> > In a Stateful Spark Streaming application I am writing t
Need help integrating Kafka with 'Stateful Spark Streaming' application.
In a Stateful Spark Streaming application I am writing the 'OutputRow' in
the 'updateAcrossEvents' but I keep getting this error (*Required attribute
'value' not found*) while it's trying to write to Kafka. I know from the
I am embarrassed to admit but I can't get a basic 'word count' to work
under Kafka/Spark streaming. My code looks like this. I don't see any
word counts in console output. Also, don't see any output in UI. Needless
to say, I am newbie in both 'Spark' as well as 'Kafka'.
Please help. Thanks.
, Something Something
mailinglist...@gmail.com wrote:
I am embarrassed to admit but I can't get a basic 'word count' to work
under
Kafka/Spark streaming. My code looks like this. I don't see any word
counts in console output. Also, don't see any output in UI. Needless to
say, I am newbie
),
ExclusionRule(organization = javax.jms),
ExclusionRule(organization = org.slf4j))
)
On Sun, Nov 24, 2013 at 11:41 PM, Something Something
mailinglist...@gmail.com wrote:
Let me start off by saying I am a newbie to Kafka, Play as well as Scala.
Trying to write an application under Play
On Mon, Nov 25, 2013 at 8:28 AM, Something Something
mailinglist...@gmail.com wrote:
Getting this error message when I run the 'compile' command:
[error] (*:update) sbt.ResolveException: unresolved dependency:
org.apache.kafka#kafka_2.9.2;0.8.0-beta1: null name not allowed
Added
Let me start off by saying I am a newbie to Kafka, Play as well as Scala.
Trying to write an application under Play Framework in which an 'Actor'
will write a message to Kafka queue.
There's sample code available
under ./core/src/main/scala/kafka/producer/ConsoleProducer.scala for me to
copy, so
