Fluentd plugin to aggregate counter messages and thresholding for them