kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Peter Bukowinski <pmb...@gmail.com>
Subject Re: Newb Trying to Publish via Kafka CLI
Date Wed, 05 Jun 2019 22:12:35 GMT
Hi,

Leave the ’ssl://' <ssl://'> part off your --broker-list argument and it should work.
You only need ‘host:port’.

—
Peter Bukowinski

> On Jun 5, 2019, at 12:41 PM, jbaile38@gmail.com wrote:
> 
> Hello,
> 
> I am trying to connect to kafka via CLI to publish messages to a topic from a windows
box.
> I’ve read the docs, googled and asked others (everyone I know just uses the GUI). 
I’m clearly missing something.
> 
> I’ve included the (masked) info I use to connect via Kafka Tool followed by a short
list of specific questions.  
> 
> Properties : General
> 	Cluster Name – ABCD, Kafka Cluster Version – 0.11, Zookeeper Host – localhost,
Zookeeper Port – 9999, Chroot path - /
> Properties : Security
> 	Type – SSL, Truststore Location – Path to kafka-trustore, Trustore Password –
abcdefghij123, Keystore Location – <blank>, Keystore Password – <blank>, Keystore
Private Key Password – <blank>
> Properties : Advanced
> 	Bootstrap servers – ssl://123.45.67.891:1234, ssl://123.45.67.892:1234, ssl://123.45.67.893:1234,
SASL mechanism – <blank>
> 
> 1. Does it matter which version of kafka I use to connect?  I'm trying with 2.12-2.2.0
> 2. I’ve attempted to use the below command, but receive the following error.  What
am I missing here?
> 
>    Kafka-console-producer --broker-list ssl://123.45.67.891:1234, ssl://123.45.67.892:1234
--producer.config C:\Users\example_user\Kafka\client-ssl.properties --topic FakeTopic
> 
>    Contents of client-ssl.properties:
>        security.protocol = SSL
>        ssl.truststore.location = C:/Users/example_user/Kafka/kafka-truststore
>        ssl.truststore.password = abcdefghij123
> 
>    Error:
>> [2019-06-05 13:01:59,592] ERROR [Producer clientId=console-producer] Connection to
node -1 (/123.45.67.891:1234) failed authentication due to: SSL handshake failed (org.apache.kafka.clients.NetworkClient)
> 


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message