You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Qi Xu <sh...@gmail.com> on 2016/03/17 02:34:31 UTC

Help: Producer with SSL did not work after upgrading the kafka 0.8.2 to Kafka 0.9

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