I have done quite a bit of research and have not been able to find the
proper solution to this.
I want to do E2E with a custom plugin which stores events to Cassandra. The
only way I could get the E2E to work though was with the following config:
host1.corp.com : collectorSource(35856) | ackChecker
cassandraStore("keyspace", "127.0.0.1:9160")
This does not account for an error storing a specific event inside the
custom plugin though. My understanding is that in this case, ackChecker
acknowledges the event before it is truly stored. Is there a better way to
handle this? Can I send the acknowledgement from inside the custom plugin?
Thanks!
