I'm attempting to use Elasticsearch custom routing in conjunction with Confluent's Kafka Elasticsearch Sink. Every thing is going well until I've run into custom routing which it doesn't seem to support.
I can't find a way to modify the query string and i was wondering if it was possible to specify "_routing" somewhere in the document? That way my Elasticsearch sink doesn't need to know about it, i can just specify it in the document being passed to Elasticsearch.
Thanks for insights,