class Kafka::Datadog::ConsumerSubscriber

def sync_group(event)
  tags = {
    client: event.payload.fetch(:client_id),
    group_id: event.payload.fetch(:group_id),
  }
  timing("consumer.sync_group", event.duration, tags: tags)
  if event.payload.key?(:exception)
    increment("consumer.sync_group.errors", tags: tags)
  end
end