You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@hadoop.apache.org by Aditya exalter <ad...@gmail.com> on 2019/07/22 08:19:52 UTC
Read kafka ssl from hdfs
Hi kafka is unable to read the keystore file from hdfs its treating as
local filesystem, any suggestions? or workarounds please
hdfs location provided hdfs://cluster1/user/test/keystore.jks and its
automatically removing the an `/` before cluster1
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:415)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:287)
at kafka.producer.NewShinyProducer.<init>(BaseProducer.scala:40)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:48)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: org.apache.kafka.common.KafkaException:
org.apache.kafka.common.KafkaException: java.io.FileNotFoundException:
hdfs:/cluster1/user/test/keystore.jks (No such file or directory)
at
org.apache.kafka.common.network.SslChannelBuilder.configure(SslChannelBuilder.java:49)
at
org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:112)
at
org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:58)
at
org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:88)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:374)
... 4 more
Caused by: org.apache.kafka.common.KafkaException:
java.io.FileNotFoundException: hdfs:/cluster1/user/test/keystore.jks (No
such file or directory)
at
org.apache.kafka.common.security.ssl.SslFactory.configure(SslFactory.java:121)
at
org.apache.kafka.common.network.SslChannelBuilder.configure(SslChannelBuilder.java:46)
... 8 more
Caused by: java.io.FileNotFoundException:
hdfs:/cluster1/user/test/keystore.jks (No such file or directory)
at java.io.FileInputStream.open0(Native Method)
Thanks & regards,
Aditya