docs: def write(self, name, **data):
          """
          Write the metric to kafka
  
          Args:
              name (str): The name of the metric to write
              data (dict): Additional data to store with the metric
          """
  
          data["name"] = name
          if not ("timestamp" in data):
              data["timestamp"] = datetime.utcnow()
  
          try:
              self.producer.send(topic=self.topic, value=data)
              self.producer.flush()
          except (KafkaTimeoutError, NoBrokersAvailable) as exc:
              logger.warning('writing metric %r failure %r', data, exc)