> Hi all,
>
> we have two environments for spark streaming job, which consumes Kafka
> topic to do calculation.
>
> Now in one environment, spark streaming job consume an non-standard
> data from kafka and throw an excepiton(not catch it in code), then the
> sreaming job is down.
>
> But in
Hi all,
we have two environments for spark streaming job, which consumes Kafka
topic to do calculation.
Now in one environment, spark streaming job consume an non-standard data
from kafka and throw an excepiton(not catch it in code), then the
sreaming job is down.
But in another environment,
