Re: when use kafka streams to(topic) method sometime throw error?

2018-03-06 Thread Sharat Joshi
unsubscribe On Mon, Mar 5, 2018 at 7:23 PM, ? ? wrote: > > hi: > I meet a problem today. > when I use kafka stream to consumer one topic and do mapValues() method, > and to another topic then .sometimes throw an error > this is code sample: > new

About configuring Kafka 2.10-0.10.2 using SASL

2017-06-05 Thread Sharat Joshi
Hi Kafka Users, I am trying to setup a Simple Authentication Mechanism for my Kafka Instance running on my Virtual Box VM. I am facing a lot of difficulty in starting the Zookeeper 3.4.10. The scenario is like this... I have a single admin User called sharjosh who's starting both the Zookeeper

Getting Lots of "Unreasonable Length" exceptions on Zk when I start my Kafka broker.

2016-05-12 Thread Sharat Joshi
Hi Experts, I have just downloaded latest Confluent Kafka 2.0.1 and started playing with it setting up a Single broker instance, a Zk and a Schema instance. When I start Zk its fine, BUT when I start my kafka server I get a lot of these... [2016-05-12 11:16:23,343] INFO Accepted socket