Re: Adding new user to the broker dynamically

2017-08-02 Thread Alexei Levashov
Hello Manikumar, I set log level to debug and couldn't define appropriate filtering so logs are a bit verbose. I still can not interpret the failure. Thx, -AL On Wed, Aug 2, 2017 at 12:01 AM, Manikumar wrote: > looks like some config error. Can you upload initial logs for both the > servers? >

Re: Adding new user to the broker dynamically

2017-08-02 Thread Manikumar
looks like some config error. Can you upload initial logs for both the servers? One user is sufficient inter broker communication. On Wed, Aug 2, 2017 at 11:04 AM, Alexei Levashov < alexei.levas...@arrayent.com> wrote: > Hello Manikumar, > > I appreciate your advice , thank you. > > I tried to us

Re: Adding new user to the broker dynamically

2017-08-01 Thread Alexei Levashov
Hello Manikumar, I appreciate your advice , thank you. I tried to use SASL_PLAINTEXT with SCRAM enabled hoping that lack of SSL will help debugging (will switch to SASL_SSL later). I have 3 brokers running on one box with different ports listeners = SASL_PLAINTEXT://:9092 listeners = SASL_PLAINTE

Re: Adding new user to the broker dynamically

2017-07-31 Thread Manikumar
Server restart is required, only if you are using SASL/PLAIN mechanism. Other mechanisms (Kerberos, Scram) restart is not required. https://issues.apache.org/jira/browse/KAFKA-4292 will help us to write custom handlers. On Tue, Aug 1, 2017 at 4:26 AM, Alexei Levashov < alexei.levas...@arrayent.c

Adding new user to the broker dynamically

2017-07-31 Thread Alexei Levashov
Hello, Is there any dynamic approach to add user to the cluster for clients connecting to the running cluster. What I mean by that - can I avoid bouncing a broker if I have to add new user with say SASL authentication? When I add a new entry to kafka_server_jaas.conf it looks like it is required t