Configuring logstash with ssl and sending message to kafka(with ssl) topic

Elastic Stack Logstash
1

I have logstash-6.5.4 (with ssl) in my local (hostname: webbox) and kafka-2.0 (with ssl) on another (hostname: kafkabox).

I am not able to receive message in kafka topic when message is sent from logstash.

Neither error message is displayed not message is sent to kafka topic. I tried to import logstash.crt into kafka's truststore but it also didn't worked.

Created logstash.crt and logstash.key with below command.

sudo openssl req -x509 -batch -nodes -days 3650 -newkey rsa:2048 -keyout /etc/logstash/logstash.key -out /etc/logstash/logstash.crt

Imported the logstash.crt into kafka's truststore file also and tried.

keytool -import -alias logstash -file logstash.crt -keystore cacerts

Logstash conf file is given below...

input {
    tcp {
    host=>"0.0.0.0" 
    port=>5514 
    type=>"syslogType"
    ssl_enable=>true
    ssl_cert=>"/etc/logstash/logstash.crt"
    ssl_key=>"/etc/logstash/logstash.key"
    ssl_verify=>false
    }
}

filter {
}

output {
    kafka {
    bootstrap_servers=>"kafkabox:9093"
    codec=>"json_lines"
    topic_id=>"a_test"
    ssl_keystore_location=>"keystore file"
    ssl_keystore_password=>"changeit"
    ssl_key_password=>"changeit"
    ssl_truststore_location=>"truststore file"
    ssl_truststore_password=>"changeit"
    security_protocol=>"SSL"
    }
}

Expecting message is sent from logstash (with SSL) to kafka (with SSL).

Thanks, RK,

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.