Re: how to detect kafka protocol

2018-08-15 Thread John Calcote
sing the same protocol as the leader will be unable to retrieve data from > the leader and will eventually drop from the ISR. > > On Wed, Aug 15, 2018 at 10:18 AM John Calcote > wrote: > > > I have a situation where I have to upgrade a distributed system in a > > pie

how to detect kafka protocol

2018-08-15 Thread John Calcote
I have a situation where I have to upgrade a distributed system in a piecemeal from plaintext to ssl between kafka clients and broker. Is there a simple way to detect from the client if it should be trying to use plaintext or ssl - from a kafka API perspective? I can do a low-level trick like open

Re: unable to reconfigure ssl truststore dynamically on broker

2018-08-15 Thread John Calcote
onfigs are listed here: > http://kafka.apache.org/documentation/#adminclientconfigs > > > On Tue, Aug 14, 2018 at 10:35 PM John Calcote > wrote: > > > Manikumar, > > > > Thank you. You are right - the security.protocol is NOT being passed to > > adminclient.properties fi

Re: unable to reconfigure ssl truststore dynamically on broker

2018-08-14 Thread John Calcote
oks like port is wrong or security.protocol config is not passed to > adminclient.properties file > > On Tue, Aug 14, 2018 at 7:23 PM John Calcote > wrote: > > > Hi, > > > > I'm using the latest kafka broker - 2.0.0 with scala 2.12. I have a > > comple

unable to reconfigure ssl truststore dynamically on broker

2018-08-14 Thread John Calcote
Hi, I'm using the latest kafka broker - 2.0.0 with scala 2.12. I have a complete SSL configuration working, but I add clients occasionally and want to be able to tell the broker to reload it's ssl truststore (as new certs have been added to it). I've followed the doc here: https://cwiki.apache.or