'Write the points to the kafka server.'

def export(self, name, columns, points):

    logger.debug('Export    {}    stats    to    Kafka'.format(name))
    data = dict(zip(columns, points))
    try:
        self.client.send(self.topic, key=name, value=data)
    except Exception as e:
        logger.error('Cannot    export    {}    stats    to    Kafka    ({})'.format(name, e))
