logstash7.4/plugins-inputs-kafka 配置参考

input{

    kafka {

                bootstrap_servers => [ "10.90.0.1:9092" ]

                topics => [ "cdr" ]

                auto_offset_reset => "latest"

                sasl_mechanism => "PLAIN"

                security_protocol => "SASL_PLAINTEXT"

                sasl_jaas_config => "org.apache.kafka.common.security.plain.PlainLoginModule required username='comleader'  password='comleader';"

   }

}

output {

        elasticsearch{

                hosts => [ "10.90.0.1:9200" ]

                index => "cdr_20210902"

                user => "elastic"

                password => "elastic"

        }

}