Adding new user to the broker dynamically

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

Re: Adding new user to the broker dynamically

; 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.com> wrote: > > > Hello, > >

Re: Adding new user to the broker dynamically

gt; 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

Python Kafka client that has support for SASL_SSL with SCRAM-SHA-256/512

Hello, could someone point me in the direction of Python Kafka client that has support for SASL_SSL with SCRAM-SHA-256/512? The reason for asking is that this lib edenhill/librdkafka seems to have configuration properties sasl.*

Questions about single consumer per partition approach

Hello, I have a few newbie questions about usage of Kafka as a messaging system. Kafka version - 0.10.1.0. 1 - Let's assume that I want to ensure time sequence of events i.e. if message A from producer was published at time t1 to partition P and message B from the same producer published to partit

Re: Questions about single consumer per partition approach

consumer group protocol guarantees that a partition > can only be assigned to one consumer, within a group, at one time. > > B > > On Wed, Dec 21, 2016 at 4:36 AM Alexei Levashov < > alexei.levas...@arrayent.com> wrote: > > > Hello, > > I have a few newbie question

Re: Questions about single consumer per partition approach

kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/ > KafkaConsumer.html#poll(long) > https://kafka.apache.org/090/javadoc/org/apache/kafka/ > common/errors/package-frame.html > > > On Wed, Dec 21, 2016 at 2:32 PM, Alexei Levashov < > alexei.levas...@arrayent.co