Re: KafkaStreams: ProducerFencedException causing StreamThread death

2018-09-28 Thread Aravind Dongara
Hi Guozhang Thanks for your reply. We are using Kafka 1.1.1 Thanks Aravind > On Sep 28, 2018, at 4:45 PM, Guozhang Wang wrote: > > Hello Aravind, > > Which version of Kafka are you currently using? What you described seems to > be fixed in the latest version already, so I want to check if

Re: Kafka ACL issue - Operation denied despite having full access to the topic

2018-09-28 Thread Vahid Hashemian
Your produce needs to have Write access to the topic. But as you mentioned All should cover Write. Which version of Kafka are you using? FYI, more authn/authz information can be found here for some of the common client operations:

Re: KafkaStreams: ProducerFencedException causing StreamThread death

2018-09-28 Thread Guozhang Wang
Hello Aravind, Which version of Kafka are you currently using? What you described seems to be fixed in the latest version already, so I want to check if you are using an older version and if yes, what's the best way to work around it. Guozhang On Thu, Sep 27, 2018 at 12:54 PM, Aravind Dongara

Re: Kafka ACL issue - Operation denied despite having full access to the topic

2018-09-28 Thread Bala
Producer using the Java API. I did configure the jaas config as per docs. It looks like is working and the authentication is succeeded but the authorization is not honoring the ACL On Friday, September 28, 2018, 11:56:24 AM EDT, Vahid Hashemian wrote: Hi Bala, What operation/command

Re: Kafka ACL issue - Operation denied despite having full access to the topic

2018-09-28 Thread Vahid Hashemian
Hi Bala, What operation/command are you trying that gives you this error? --Vahid On Fri, Sep 28, 2018 at 7:12 AM Bala wrote: > I have a kafka with kerberos security and trying to use the ACL and am not > able to make it work. > > Here is the error I am seeing in the server log.[2018-09-28

Kafka ACL issue - Operation denied despite having full access to the topic

2018-09-28 Thread Bala
I have a kafka with kerberos security and trying to use the ACL and am not able to make it work. Here is the error I am seeing in the server log.[2018-09-28 14:06:54,152] INFO Principal = User:storm-mytestcluster is Denied Operation = Describe from host = on resource = Topic:icd_alpha

Re: Have connector be paused from start

2018-09-28 Thread Svante Karlsson
Sound like a workflow/pipeline thing in jenkins (or equivalent) to me. Den ons 26 sep. 2018 kl 17:27 skrev Rickard Cardell : > Hi > Is there a way to have a Kafka Connect connector begin in state 'PAUSED'? > I.e I would like to have the connector set to paused before it can process > any data

Re: How to setup Kafka security ? but only for some

2018-09-28 Thread Tobias Eriksson
That is exactly what I am after I think Now I need to figure out how to do the Access Control (ACL) too Thanx -Tobias On 2018-09-28, 12:33, "Daniel Nägele" wrote: Hello Tobias, you can declare multiple listeners, I use the following setup for instance:

Re: How to setup Kafka security ? but only for some

2018-09-28 Thread Daniel Nägele
Hello Tobias, you can declare multiple listeners, I use the following setup for instance: listeners=PLAINTEXT://fqdn:9092,SASL_SSL://fqdn:9093 I plan to turn PLAINTEXT off however, because why not encrypt the internal communication too. Best regards, Daniel On 9/27/18 10:09 AM, Tobias