Allow JSON string in Elasticsearch Flow and Sink

[djm1329]

Short description

ElasticsearchFlow (and ElasticsearchSink) are missing a way to pass strings that already represent JSON docs.

Details

It appears the flow wants to convert whatever is flowing through to a string itself (using spray json). The use case I am thinking of is where the user of the connector already has a JSON string at hand (read from a file say, or obtained via some other means). Right now, AFAICT the user needs to pre-parse such a string to a JsValue and pass that, only to have the flow re-serialize to a string.

[2m]

Hi @douglas, this sounds good to me as additional API. Are you willing to work on a PR to implement this? :)

[djm1329]

Yes I can give it a shot, thanks! Doug

…

On Jul 10, 2019, at 05:53, Martynas Mickevičius ***@***.***> wrote: Hi @douglas <https://github.com/douglas>, this sounds good to me as additional API. Are you willing to work on a PR to implement this? :) — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub <#1825?email_source=notifications&email_token=ABMTCAO4TED6NXE7VFGP6NLP6XLV7A5CNFSM4H7HDWK2YY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGODZTLRJA#issuecomment-510048420>, or mute the thread <https://github.com/notifications/unsubscribe-auth/ABMTCAME7WEOG7TOSPVUWM3P6XLV7ANCNFSM4H7HDWKQ>.

[ennru]

I looked into it more and discovered it is already possible with the Scala DSL. So I added test cases and opened the Java API for it in #1862.

[ennru]

Fixed with #1862