Method: Kafka::Datadog::ProducerSubscriber#buffer_overflow

Defined in:
lib/kafka/datadog.rb

#buffer_overflow(event) ⇒ Object 



307
308
309
310
311
312
313
314
 
# File 'lib/kafka/datadog.rb', line 307

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

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