Bei der Verwendung von Syslog-kafka traten einige Python-Syntaxfehler auf

Question

Ich muss eine Nachricht an meinen Kafka-Cluster senden. Das mache ich sohttps://syslogng-kafka.readthedocs.io/en/latest/installation.html , und /etc/syslog-ng/conf.d/kafka.confwie

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

habe einen Fehler wie: Bildbeschreibung hier eingeben

Answer 1

Ich kenne dieses Python-basierte Kafka-Ziel nicht, aber ab Version 3.21syslog-ng hat ein natives C-basiertes Kafka-Ziel. Vielleicht möchten Sie das mal ausprobieren. Sie erhaltenPakete für aktuelle Syslog-ng-Versionen hier.