Relative Content

Tag Archive for regexapache-sparkpysparkapache-kafkaspark-streaming

java regex not working for spark kafka reader

We use kafka reader with spark 3.4.3 to read data from topic. we consume two topics k8s-v2.in.mongo.mongo-conn.ninja.xyz.PolicyDetail and k8s-v2.in.mongo.mongo-conn.ninja.xyz.PolicyDetailHistory
The code looks like this