Search code examples
elasticsearchstreamsets

How do you add routing for elasticsearch destination in 2.5

I'm using StreamSets (2.5.1.1) to pipe data to Elasticsearch (5.4.1). My index requires routing but I do not see how to add routing to the Elasticsearch destination in my pipeline. I thought I could just add a "routing" http param but it needs to be dynamic and SS doesn't like my EL expression to my record (tried something like ${record:value("/myRoutingId")} as a value.

What is the right way to add routing?

Solution

  • This feature is coming in SDC 2.7.0.0 under SDC-5244.