I am reading data from kafka apply some transformation, update data schema and push it to elastic search.
I am using spark (2.2.0), elasticsearch-spark (6.2.3).
There is a api with spark streaming which can accept RDD with index name (JavaEsSpark.saveJsonToEs(rdd, index))
I can't find api with structured streaming which can accept Json instead of structured data.
Can someone help ?