Method: Kafka::Prometheus::ProducerSubscriber#ack_message

Defined in:
lib/kafka/prometheus.rb

#ack_message(event) ⇒ Object 



246
247
248
249
250
251
252
253
254
 
# File 'lib/kafka/prometheus.rb', line 246

def ack_message(event)
  key = { client: event.payload.fetch(:client_id), topic: event.payload.fetch(:topic) }

  # Number of messages ACK'd for the topic.
  @ack_messages.increment(labels: key)

  # Histogram of delay between a message being produced and it being ACK'd.
  @ack_delay.observe(event.payload.fetch(:delay), labels: key)
end