☰

使用 Syslog-kafka 时出现一些 python 语法错误

tag-icon • tag-icon python3 syslog
使用 Syslog-kafka 时出现一些 python 语法错误

我需要向我的 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);
};

出现如下错误： 在此处输入图片描述

答案1

我不知道这个基于python的Kafka目标，但是从3.21版本开始，syslog-ng 有一个基于 C 的原生 Kafka 目标。您可能想尝试使用它。您可以获得此处提供了适用于最新 syslog-ng 版本的软件包。

相关内容