Method: Kafka::Datadog::ProducerSubscriber#topic_error

Defined in:
lib/kafka/datadog.rb

#topic_error(event) ⇒ Object 



351
352
353
354
355
356
357
358
 
# File 'lib/kafka/datadog.rb', line 351

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

  increment("producer.ack.errors", tags: tags)
end