my configuration like this:
input {
file {
path => "/usr/share/logstash/agent/tmp/*"
start_position => "beginning"
}
}
filter {
}
output {
kafka {
bootstrap_servers => "SASL_SSL://kafka-ons-internet.aliyun.com:8080"
topic_id => ["class100LogKafka"]
security_protocol => "SASL_SSL"
sasl_mechanism => "ONS"
jaas_path => "/home/zhoudazhuang/class100/docker/docker-repo/seelog-logstash/agent/jaas.conf"
ssl_truststore_password => "KafkaOnsClient"
ssl_truststore_location => "/home/zhoudazhuang/class100/docker/docker-repo/seelog-logstash/agent/kafka.client.truststore.jks"
# sasl_kerberos_service_name => "kafka"
codec => json
}
}
the track log say:
error=>"Failed to construct kafka producer"
"RUBY.start_workers(/home/zhoudazhuang/class100/bin-software/logstash-5.4.0/logstash-core/lib/logstash/pipeline.rb:288)", "RUBY.run(/home/zhoudazhuang/class100/bin-software/logstash-5.4.0/logstash-core/lib/logstash/pipeline.rb:214)", "RUBY.start_pipeline(/home/zhoudazhuang/class100/bin-software/logstash-5.4.0/logstash-core/lib/logstash/agent.rb:398)", "java.lang.Thread.run(java/lang/Thread.java:745)"]}
It troubled me for a long time,Can anyone help me to resolve this issue?