Solved it . Thanks
On Wed, Dec 9, 2015 at 10:39 PM, Ritesh Sinha <
kumarriteshranjansi...@gmail.com> wrote:
> Thanks Ben for your prompt reply.
>
> But when I am trying to start the producer it throws this error.
>
> org.apache.kafka.common.KafkaException: Failed to construct kafka producer
> at
Thanks Ben for your prompt reply.
But when I am trying to start the producer it throws this error.
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:321)
at
org.apache.kafka.clients.producer.KafkaProdu
Hi Ritesh
You just need to create yourself a text file called client-ssl.properties or
similar in the directory your running from. In that file you put your SSL
client information. Something like this:
security.protocol = SSL
ssl.truststore.location = "/var/private/ssl/kafka.client.truststore.
Hi,
I am following the kafka documentation to create encryption and
authentication while sending message to kafka by ssl
I got stuck at these commands
kafka-console-producer.sh --broker-list localhost:9093 --topic test
--producer.config *client-ssl.properties*
kafka-console-consumer.sh --boot
