<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>question Problem configuring SSL secure connection in Kafka using Cloudera Manager 5.13.0 and S.O Centos 6 in Support Questions</title>
    <link>https://community.cloudera.com/t5/Support-Questions/Problem-configuring-SSL-secure-connection-in-Kafka-using/m-p/81304#M37459</link>
    <description>&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;Hi&amp;nbsp; People&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;I am trying to make a secure communication between a producer and a consumer in Kafka (1.0.1)&lt;/P&gt;&lt;P&gt;by enabling the SSL protocol, however after the generation of the certificates and configure&lt;/P&gt;&lt;P&gt;the server.properties file through the Cloudera Manager(Version 5.13.0 and S.O Centos 6), when&lt;/P&gt;&lt;P&gt;I made the connection test using the openssl s_client -debug -connect localhost:9093 -tls1&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;I have the following error, someone can help me&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;CONNECTED(00000003)&lt;/P&gt;&lt;P&gt;write to 0x1a9e670 [0x1ae9713] (155 bytes =&amp;gt; 155 (0x9B))&lt;/P&gt;&lt;P&gt;0000 - 16 03 01 00 96 01 00 00-92 03 01 5b c6 7c 3d 62&amp;nbsp; &amp;nbsp;...........[.|=b&lt;/P&gt;&lt;P&gt;0010 - 53 b1 25 75 34 88 fd 60-7a 41 93 51 68 3a 63 d5&amp;nbsp; &amp;nbsp;S.%u4..`zA.Qh:c.&lt;/P&gt;&lt;P&gt;0020 - 57 14 37 6e 78 bd bc 38-e4 d7 ef 00 00 4c c0 14&amp;nbsp; &amp;nbsp;W.7nx..8.....L..&lt;/P&gt;&lt;P&gt;0030 - c0 0a 00 39 00 38 00 88-00 87 c0 0f c0 05 00 35&amp;nbsp; &amp;nbsp;...9.8.........5&lt;/P&gt;&lt;P&gt;0040 - 00 84 c0 13 c0 09 00 33-00 32 c0 12 c0 08 00 9a&amp;nbsp; &amp;nbsp;.......3.2......&lt;/P&gt;&lt;P&gt;0050 - 00 99 00 45 00 44 00 16-00 13 c0 0e c0 04 c0 0d&amp;nbsp; &amp;nbsp;...E.D..........&lt;/P&gt;&lt;P&gt;0060 - c0 03 00 2f 00 96 00 41-00 0a 00 07 c0 11 c0 07&amp;nbsp; &amp;nbsp;.../...A........&lt;/P&gt;&lt;P&gt;0070 - c0 0c c0 02 00 05 00 04-00 ff 01 00 00 1d 00 0b&amp;nbsp; &amp;nbsp;................&lt;/P&gt;&lt;P&gt;0080 - 00 04 03 00 01 02 00 0a-00 08 00 06 00 19 00 18&amp;nbsp; &amp;nbsp;................&lt;/P&gt;&lt;P&gt;0090 - 00 17 00 23 00 00 00 0f-00 01 01&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; ...#.......&lt;/P&gt;&lt;P&gt;read from 0x1a9e670 [0x1ae51c3] (5 bytes =&amp;gt; 5 (0x5))&lt;/P&gt;&lt;P&gt;0005 - &amp;lt;SPACES/NULS&amp;gt;&lt;/P&gt;&lt;P&gt;write to 0x1a9e670 [0x1aeebe0] (7 bytes =&amp;gt; 7 (0x7))&lt;/P&gt;&lt;P&gt;0000 - 15 03 01 00 02 02 46&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; ......F&lt;/P&gt;&lt;P&gt;140660245464904:error:1408F10B:SSL routines:SSL3_GET_RECORD:wrong version number:s3_pkt.c:339:&lt;/P&gt;&lt;P&gt;---&lt;/P&gt;&lt;P&gt;no peer certificate available&lt;/P&gt;&lt;P&gt;---&lt;/P&gt;&lt;P&gt;No client certificate CA names sent&lt;/P&gt;&lt;P&gt;---&lt;/P&gt;&lt;P&gt;SSL handshake has read 5 bytes and written 7 bytes&lt;/P&gt;&lt;P&gt;---&lt;/P&gt;&lt;P&gt;New, (NONE), Cipher is (NONE)&lt;/P&gt;&lt;P&gt;Secure Renegotiation IS NOT supported&lt;/P&gt;&lt;P&gt;Compression: NONE&lt;/P&gt;&lt;P&gt;Expansion: NONE&lt;/P&gt;&lt;P&gt;SSL-Session:&lt;/P&gt;&lt;P&gt;Protocol&amp;nbsp; : TLSv1&lt;/P&gt;&lt;P&gt;Cipher&amp;nbsp; &amp;nbsp; : 0000&lt;/P&gt;&lt;P&gt;Session-ID:&lt;/P&gt;&lt;P&gt;Session-ID-ctx:&lt;/P&gt;&lt;P&gt;Master-Key:&lt;/P&gt;&lt;P&gt;Key-Arg&amp;nbsp; &amp;nbsp;: None&lt;/P&gt;&lt;P&gt;Krb5 Principal: None&lt;/P&gt;&lt;P&gt;PSK identity: None&lt;/P&gt;&lt;P&gt;PSK identity hint: None&lt;/P&gt;&lt;P&gt;Start Time: 1539734589&lt;/P&gt;&lt;P&gt;Timeout&amp;nbsp; &amp;nbsp;: 7200 (sec)&lt;/P&gt;&lt;P&gt;Verify return code: 0 (ok)&lt;/P&gt;&lt;P&gt;---&lt;/P&gt;&lt;P&gt;Additionally my logs says&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;2018-10-11 12:38:16,510 WARN org.apache.kafka.common.network.SslTransportLayer: Failed to send SSL Close message&lt;/P&gt;&lt;P&gt;java.io.IOException: Connection reset by peer&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://sun.nio.ch/" target="_blank" rel="noopener noreferrer"&gt;sun.nio.ch&lt;/A&gt;.FileDispatcherImpl.write0(Native Method)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://sun.nio.ch/" target="_blank" rel="noopener noreferrer"&gt;sun.nio.ch&lt;/A&gt;.SocketDispatcher.write(SocketDispatcher.java:47)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://sun.nio.ch/" target="_blank" rel="noopener noreferrer"&gt;sun.nio.ch&lt;/A&gt;.IOUtil.writeFromNativeBuffer(IOUtil.java:93)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://sun.nio.ch/" target="_blank" rel="noopener noreferrer"&gt;sun.nio.ch&lt;/A&gt;.IOUtil.write(IOUtil.java:65)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://sun.nio.ch/" target="_blank" rel="noopener noreferrer"&gt;sun.nio.ch&lt;/A&gt;.SocketChannelImpl.write(SocketChannelImpl.java:487)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:212)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:175)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:703)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:61)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.Selector.doClose(Selector.java:739)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.Selector.close(Selector.java:727)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:520)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at org.apache.kafka.common.network.Selector.poll(Selector.java:412)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at kafka.network.Processor.poll(SocketServer.scala:551)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://kafka.network.processor.run/" target="_blank" rel="noopener noreferrer"&gt;kafka.network.Processor.run&lt;/A&gt;(SocketServer.scala:468)&lt;/P&gt;&lt;P&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; at&lt;SPAN&gt;&amp;nbsp;&lt;/SPAN&gt;&lt;A href="https://java.lang.thread.run/" target="_blank" rel="noopener noreferrer"&gt;java.lang.Thread.run&lt;/A&gt;(Thread.java:745)&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;PROCEDURE TO MAKE THE CERTIFICATES&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;CERTIFICATION AUTHORITY&lt;/P&gt;&lt;P&gt;=======================&lt;/P&gt;&lt;P&gt;openssl req -new -newkey rsa:4096 -days 365 -x509 -subj "/CN=Kafka-Security-CA" -keyout ca-key -out ca-cert -nodes&lt;/P&gt;&lt;P&gt;openssl req -new -newkey rsa:4096 -days 365 -x509 -subj "/CN=Kafka-Security-CA" -keyout ca-key -out ca-cert -nodes&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;CREATING SERVER CERTIFICATE&lt;/P&gt;&lt;P&gt;===========================&lt;/P&gt;&lt;P&gt;Using my hostname (quickstart.cloudera)&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;keytool -genkey -keystore kafka.server.keystore.jks -validity 365 -storepass $SRVPASS -keypass $SRVPASS&amp;nbsp; -dname "CN=quickstart.cloudera" -storetype pkcs12&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;CREATE A CERTIFICATION REQUEST FILE&lt;/P&gt;&lt;P&gt;===================================&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.server.keystore.jks -certreq -file cert-file -storepass $SRVPASS -keypass $SRVPASS&lt;/P&gt;&lt;P&gt;openssl x509 -req -CA ca-cert -CAkey ca-key -in cert-file -out cert-signed -days 365 -CAcreateserial -passin pass:$SRVPASS&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;CHECK CERTIFICATES&lt;/P&gt;&lt;P&gt;===================&lt;/P&gt;&lt;P&gt;keytool -printcert -v -file cert-signed&lt;/P&gt;&lt;P&gt;keytool -list -v -keystore kafka.server.keystore.jks&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.server.truststore.jks -alias CARoot -import -file ca-cert -storepass $SRVPASS -keypass $SRVPASS -noprompt&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;IMPORT CA AND THE SIGNED SERVER CERTIFICATE INTO KEYSTORE&lt;/P&gt;&lt;P&gt;=========================================================&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.server.keystore.jks -alias CARoot -import -file ca-cert -storepass $SRVPASS -keypass $SRVPASS -noprompt&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.server.keystore.jks -import -file cert-signed -storepass $SRVPASS -keypass $SRVPASS -noprompt&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.client.keystore.jks -alias localhost -certreq -file cert-file&lt;/P&gt;&lt;P&gt;openssl x509 -req -CA ca-cert -CAkey ca-key -in cert-file -out cert-signed -days $VALIDITY -CAcreateserial -passin pass:$PASSWORD&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.client.keystore.jks -alias CARoot -import -file ca-cert&lt;/P&gt;&lt;P&gt;keytool -keystore kafka.client.keystore.jks -alias localhost -import -file cert-signed&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;////////////////////////////&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;KAFKA SERVER PROPERTIES&lt;/P&gt;&lt;P&gt;listeners=PLAINTEXT://0.0.0.0:9092,SSL://0.0.0.0:9093&lt;/P&gt;&lt;P&gt;ssl.keystore.location=/var/private/ssl-new-5/kafka.server.keystore.jks&lt;/P&gt;&lt;P&gt;ssl.keystore.password=XXXXXX&lt;/P&gt;&lt;P&gt;ssl.key.password=XXXXXX&lt;/P&gt;&lt;P&gt;ssl.truststore.location=/var/private/ssl-new-5/kafka.server.truststore.jks&lt;/P&gt;&lt;P&gt;ssl.truststore.password=XXXXXXX&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;offsets.topic.replication.factor=1&lt;/P&gt;&lt;P&gt;transaction.state.log.replication.factor=1&lt;/P&gt;&lt;P&gt;transaction.state.log.min.isr=1&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;I appreciate any help to solve this problem&lt;/P&gt;</description>
    <pubDate>Fri, 16 Sep 2022 13:49:12 GMT</pubDate>
    <dc:creator>JuanPa</dc:creator>
    <dc:date>2022-09-16T13:49:12Z</dc:date>
  </channel>
</rss>

