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 버전용 패키지는 여기에서 확인하세요..