Deduplicating input in Kapacitor

InfluxDB 1 Kapacitor
1

Hi,

I currently run two InfluxDB instances with influx-relay. They both have a subscription to send data to a Kapacitor instance.

Therefore, kapacitor receives the data two times, messing up counts.

Is there any way to use a distinct() call with time to deduplicate, without having to send the time as a field, as distinct(‘time’) does not seem to work.

Best,
Anthony

2

I’m looking for similar functionality. We have data being inserted at regular intervals, but there is overlap, which InfluxDB handles fine. But Kapacitor counts the duplicates twice while processing the stream. Trying to learn how to make it not do that.