19 avril 2018 15:28
> *À :* Chauvet, Thomas
> *Objet :* Re: Flink / Kafka unit testing with scalatest-embedded-kafka
>
>
>
> Looking at your code, Kafka broker was not started.
>
>
>
> Was there running broker on localhost ?
>
>
>
> Cheers
>
>
>
> On
: Flink / Kafka unit testing with scalatest-embedded-kafka
Looking at your code, Kafka broker was not started.
Was there running broker on localhost ?
Cheers
On Thu, Apr 19, 2018 at 6:23 AM, Chauvet, Thomas
mailto:thomas.chau...@ercom.fr>> wrote:
Hi,
I would like to « unit test » a job flin
Hi,
I would like to < unit test > a job flink with Kafka as source (and Sink). I am
trying to use the library scalatest-embedded-kafka to simulate a Kafka for my
test.
For example, I would like to get data (string stream) from Kafka, convert it
intro uppercase and put it into another topic.
N
