Re: Free spots available for 6 week Apache Kafka course

2022-03-07 Thread Bala vinayagam
Interested. Thanks,Bala Sent from Yahoo Mail on Android On Mon, 7 Mar 2022 at 23:50, vinay deshpande wrote: Hi Justin, I'm interested in the course. Thanks, Vinay On Mon, Mar 7, 2022 at 9:30 AM David Luu wrote: > Sorry my bad, didn't notice replies go back to the grou

Kafka consumer error in storm topology

2018-10-01 Thread Bala
Not sure if this is a kafka issue,but I am seeing this on a kerberized cluster and seeing this exception in kafka spout.  java.nio.channels.ClosedChannelException: null     at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) ~[stormjar.jar:?]     at kafka.consumer.SimpleCons

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

2018-09-29 Thread Bala
creating acls for "User:storm-mytestcluster" principal. On Sat, Sep 29, 2018 at 9:04 PM Bala wrote: >  Yes, I followed all the docs and thing is it's connecting as expected and > sending the right user to the server. The problem is that when I list ACL's > I am seeing tha

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

2018-09-29 Thread Bala
er.ibm.com/opentech/2017/05/31/kafka-acls-in-practice/ --Vahid On Fri, Sep 28, 2018 at 9:13 AM Bala wrote: > 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 honor

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

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 (kafka.