Method: Kafka::Prometheus::ProducerSubscriber#buffer_overflow

Defined in:
lib/kafka/prometheus.rb

#buffer_overflow(event) ⇒ Object 



226
227
228
229
 
# File 'lib/kafka/prometheus.rb', line 226

def buffer_overflow(event)
  key = { client: event.payload.fetch(:client_id), topic: event.payload.fetch(:topic) }
  @produce_errors.increment(labels: key)
end