使用 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

我不知道這個基於 python 的 Kafka 目的地，但從版本 3.21 開始，syslog-ng 有一個基於 C 的原生 Kafka 目的地。您可能想嘗試使用它。你可以得到最新 syslog-ng 版本的軟體包在這裡。