Hi folks, We just finished the upgrade from 0.8.2 to 0.9 with the instructions in Kafka web site (that set the protocol version as 0.8.2.x in Kafka server 0.9). After the upgrade, we want to try the producer with SSL endpoint, but never worked. Here's the error:
~/kafka_2.11-0.9.0.0$ ./bin/kafka-console-producer.sh --topic testtopic1 --broker-list <SSL endpoint> --producer.config ./config/producer.properties ...... [2016-03-17 01:24:46,481] WARN Error while fetching metadata with correlation id 0 : {testtopic1=UNKNOWN} (org.apache.kafka.clients.NetworkClient) [2016-03-17 01:24:46,613] WARN Error while fetching metadata with correlation id 1 : {testtopic1=UNKNOWN} (org.apache.kafka.clients.NetworkClient) [2016-03-17 01:24:46,759] WARN Error while fetching metadata with correlation id 2 : {testtopic1=UNKNOWN} (org.apache.kafka.clients.NetworkClient) [2016-03-17 01:24:46,901] WARN Error while fetching metadata with correlation id 3 : {testtopic1=UNKNOWN} (org.apache.kafka.clients.NetworkClient) [2016-03-17 01:24:47,046] WARN Error while fetching metadata with correlation id 4 : {testtopic1=UNKNOWN} (org.apache.kafka.clients.NetworkClient) In producer.properties, I specified all security information needed, as below: security.protocol=SSL ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1 ssl.keystore.type=JKS ssl.keystore.location=/usr/share/kafka/config/server.keystore ssl.keystore.password=Password ssl.key.password=Password ssl.truststore.type=JKS ssl.truststore.location=/usr/share/kafka/config/server.keystore ssl.truststore.password=Password In server side, I don't see any obvious error. Any idea or hint is very appreciated. Thanks a lot. Thanks, Qi