Al usar Syslog-kafka se produjo un error de sintaxis de Python

Question

Necesito enviar un mensaje a mi clúster kafka, hago lo mismo asíhttps://syslogng-kafka.readthedocs.io/en/latest/installation.html , y, /etc/syslog-ng/conf.d/kafka.confcomo

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);
};

obtuve un error como: ingrese la descripción de la imagen aquí

Answer 1

No conozco este destino de Kafka basado en Python, pero a partir de la versión 3.21,syslog-ng tiene un destino Kafka nativo basado en C. Quizás quieras intentar usar eso. Puedes obtenerpaquetes para versiones recientes de syslog-ng aquí.