We have an IOT device and the logs generated from this device are received by a logstash instance as input and sent the same logs to the cloudamqp queue as output.
Working condition -- > Logstash version 6.8.22
Not working --> Today, we upgraded Logstash to 7.17.5 and the issue started with the below error.
We are using a helm chart to deploy the application in our EKS cluster
" {:exception=>Java::JavaxNetSsl::SSLException, :message=>"Unsupported or unrecognized SSL message"}"
When we searched about this issue, some docs said about the wrong protocol we are using with the logstash config. But, we are not sure, what change we need to make to fix this
The issue was with the Cloudamqp port. We were using the default port 5672 instead of TLS port 5671. I have explicitly added that port to the output section and now it's working fine
Change
output {
rabbitmq {
port => 5671 *This TLS port added here to fix the issue*
vhost => "device"
host => "xxxxx"
ssl => true
exchange => "logs"
exchange_type => "x-consistent-hash"
passive => true
user => "${RABBITMQ_USERNAME}"
password => "${RABBITMQ_PASSWORD}"
key => "%{+SSS}" # Hashing Key based on the current fraction of a second
}
}
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.