ElasticSearchSink.process() can't catch exception when Es down
Opened this issue · 0 comments
selqgun commented
dear Cognitree:
I try this es-sink for testing, find that ElasticSearchSink.process() can't catch exception when Es down.
It is seem that the exception message was send to BulkProcessor.Listener.afterBulk() and can,t throw.
so the logs was consumed with no stored, can you help to this issue?