При использовании Syslog-kafka возникли некоторые ошибки синтаксиса Python

Question

Мне нужно отправить сообщение в мой кластер Kafka, я делаю то же самое следующим образомhttps://syslogng-kafka.readthedocs.io/en/latest/installation.html , и /etc/syslog-ng/conf.d/kafka.confкак

destination authlog_to_kafka {
    python(
        class("syslogng_kafka.kafkadriver.KafkaDestination")
            on-error("fallback-to-string")
            options(
                hosts("dev-idms-kafka001-ncl.nfra.io:9092")
                topic("auth-log")
                verbose("True")
                display_stats("True")
                )
    );
};
log {
    source(s_sys);
    destination(authlog_to_kafka);
};

возникла ошибка типа: введите описание изображения здесь

Answer 1

Я не знаю этого пункта назначения Kafka на основе Python, но начиная с версии 3.21,syslog-ng имеет собственный пункт назначения Kafka на основе C. Вы можете попробовать использовать это. Вы можете получитьпакеты для последних версий syslog-ng здесь.