Rule Engine for Spark

[Cassa L]

Hi,
 Has anyone used rule engine with spark streaming? I have a case where data
is streaming from Kafka and I need to apply some rules on it (instead of
hard coding in a code).

Thanks,
LCassa