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 バージョンのパッケージはこちら。