Elasticsearch Structured streaming api for bulk insert json documents

Elastic Stack Elasticsearch
1

Hi,

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 ?

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.