Как вы добавляете маршрутизацию для destinationsearch destination в 2.5
Я использую StreamSets (2.5.1.1) для передачи данных в Elasticsearch (5.4.1). Мой индекс требует маршрутизации, но я не вижу, как добавить маршрутизацию к месту назначения Elasticsearch в моем конвейере. Я подумал, что мог бы просто добавить параметр http "маршрутизации", но он должен быть динамическим, и SS не нравится мое выражение EL в моей записи (пробовал что-то вроде ${record:value("/myRoutingId")} в качестве значения.
Как правильно добавить маршрутизацию?
1 ответ
Решение