Release Date for Kafka 0.8.2

Kafka Team, We are currently using the 0.8.2 beta version with a patch for KAFKA-1738. Do you have any updates on when 0.8.2 final version will be released? Thanks, Srividhya This email and any files transmitted with it are confidential, proprietary and intended solely for the individual or e

Is replicating partitions cover disaster recovery

If the entire kafka cluster is down, then the cluster mirror can be a solution for disaster recovery. If a hardware failure that corrupts the disk of a node in the kafka cluster, and if there are enough replications configured for each topic partitions, would that be a solution for disaster reco

Kafka security

Kafka Team, I am trying to integrate kafka security. I was able to authenticate using SSL(TLS) with a single broker/client and a two node set up. I started reading about ACLs and my understanding is ACLs can be configured with kerberos principals. Is there a way ACLs can be configured with custom

Re: Kafka security

client cert - the subject of the client cert will be used as the ACL user. > > Thanks > Tom > > On Wed, Apr 20, 2016 at 2:12 PM, Srividhya Shanmugam < > srivishanmu...@gmail.com> wrote: > > > Kafka Team, > > > > I am trying to integrate kafka secur

Re: Kafka security

through java client for producers and cnsumers. Is that correct? Thanks Sri On Wed, Apr 20, 2016 at 9:29 AM, Tom Crayford wrote: > Yes: http://kafka.apache.org/documentation.html#security_ssl > > On Wed, Apr 20, 2016 at 2:29 PM, Srividhya Shanmugam < > srivishanmu...@g

Re: Kafka security

Thanks again. That clarified the question. On Wed, Apr 20, 2016 at 9:55 AM, Tom Crayford wrote: > Yes > > On Wed, Apr 20, 2016 at 2:52 PM, Srividhya Shanmugam < > srivishanmu...@gmail.com> wrote: > > > Yes, I followed those steps for setting up SSL based aut

Unable to read from the beginning using High level consumer API

Kafka Team, I am using high level consumer API as shown below to read contents from the topic. Properties props = new Properties(); props.put("zookeeper.connect" ,"localhost:2181"); props.put" zookeeper.session.timeout.ms","1

Zookeeper offset

Kafka Team, In the integration environment Kafka and zookeeper are running under supervision. Once in a while when zookeeper and kafka are shut-down and started back again, the consumers are not able to read the data from the topic. I am not seeing any exceptions in the log. The consumer offset