Hi All,
I am trying to run the elastic search sink to pick up enriched events in kinesis however I am not sure it is running correctly. I am able to start the jar without errors (I can produce errors if I remove a config key) however it does not seem to do anything at all, running it using the Dorg logger also produces no output whatsoever - I have got the scala collector and enricher running successfully and emitting events to kinesis I just cant run the ES sink! Any hints/tips welcomed.
Thanks