Hi Nick,
When you get the failed data, the logic for implementing the side output is
similar to the logic for extending the
ActionRequestFailureHandler#onFailure method to output the data to other
places.
Thanks, vino.
Nick Triller 于2018年8月31日周五 下午9:08写道：
> Hi all,
>
>
>
> is it possible to fu
Hi all,
is it possible to further process data that could not be persisted by the
Elasticsearch6 sink without breaking checkpointing?
As I understand, the onFailure callback can't be used to forward rejected data
into a separate stream.
I would like to extend the sink if this use case is not co
