Generate data with apache kafka and receive it using spark streaming
<p>I would like to know how can I do in the same program to generate random data using apache Kafka and receive it using spark streaming.</p>

<p>Let's show a use case:</p>

<p>I want to generate random data like this -> (A, B, ab@hotmail.com) while X seconds.
And then I want to receive this data for processing it in real time (while I'm receiving it), and if the second parameter is B send an email to 'ab@hotmail.com' with the following message: "The first parameter is A". </p>

<p>I know that I have to start a zookeeper server, then start a kafka broker, then create a topic, and then a producer for produce and send this data. For create the connection between kafka and streaming I need to use "createStream" function. But I don't know how to use a producer to send this data and then receive it with spark streaming for processing it. All this in the same program and using Java.</p>

<p>Any help? Thank you. </p>