Add anomaly detection for # of messages sent to Kafka

Change-Id: I93318043418fa3058b440e32ee525028910df961