Re: how to detect kafka protocol

2018-08-15 Thread John Calcote
Thanks Eric, The situation is like this - we have only a single broker and it has to make a clean break from PLAINTEXT, but our clients are all either old or new (upgraded to SSL). The old ones will obviously not be able to work against the upgraded broker. The problem is I have 18 (only a slight

Re: how to detect kafka protocol

2018-08-15 Thread Eric Azama
Zookeeper definitely has the information about endpoints and protocol. The /brokers/ids/ paths in zookeeper contains the endpoints that are open on the broker. I have doubts that you'll be able to make this change without any downtime though. To my knowledge, clients are only capable of using one

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