code: def export(self, name, columns, points):
          
          logger.debug("Export {} stats to Kafka".format(name))
  
          # Create DB input
          data = dict(zip(columns, points))
  
          # Send stats to the kafka topic
          # key=<plugin name>
          # value=JSON dict
          try:
              self.client.send(self.topic,
                               key=name,
                               value=data)
          except Exception as e:
              logger.error("Cannot export {} stats to Kafka ({})".format(name, e))
docs: Write the points to the kafka server.