Method: Kafka::Datadog::ProducerSubscriber#ack_message

Defined in:
lib/kafka/datadog.rb

#ack_message(event) ⇒ Object 



338
339
340
341
342
343
344
345
346
347
348
349
 
# File 'lib/kafka/datadog.rb', line 338

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

  # Number of messages ACK'd for the topic.
  increment("producer.ack.messages", tags: tags)

  # Histogram of delay between a message being produced and it being ACK'd.
  histogram("producer.ack.delay", event.payload.fetch(:delay), tags: tags)
end