class Kafka::Datadog::ProducerSubscriber

def buffer_overflow(event)
  tags = {
    client: event.payload.fetch(:client_id),
    topic: event.payload.fetch(:topic),
  }
  increment("producer.produce.errors", tags: tags)
end