I have an application that writes to a kafka queue, and one that reads those messages from the kafka queue. I want to output an prometheus metric (a gauge) that shows a count as the value with client/event type of the message as labels. I want this count to increment and decrement based on whether the event was published from application A and decrement when it is consumed by application B.