logstash 升级后报错 Input kafka

你的配置是什么？要贴一下，相关信息完整才能帮忙定位问题

我的logstash 配置文件：
 
input{        kafka{
               client_id => "p1"
               bootstrap_servers => "127.0.0.1:9290"  #我随便写了一个
               group_id => "p1"
               security_protocol => "SASL_PLAINTEXT"
               sasl_mechanism => PLAIN
               codec => "json"
               jaas_path => "/usr/share/logstash/jaas.conf"
               topics => ["p1"]
              
        }
}



output{

        elasticsearch{
                hosts => ["127.0.0.1:9202"]
                user => ""
                password => ""
                action => "index"
                index => "p-%{+YYYY.MM}"
                codec => "json"
        }
        
}

有尝试打开 debug 日志看下有无有价值的输出吗？
https://www.elastic.co/guide/e ... .html