Re: Does kafka use sbt (or) gradle

Hi Kafka Camus Users, I have a quick question on the capabilities of Camus consumption. We have a scenario wherein we want to consume data from two independent Broker/Zk Clusters on two different Data Centers. Both of these Broker clusters have the same named topic. Our Camus Job running on a

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

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 StreamsBuilder().stream(xxxtopic, Consumed.wi

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

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 connection

About configuring Kafka 2.10-0.10.2 using SASL

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 an