Fwd: Broker Variable Performance due to Disk I/O Issue

Hi, This isn't a big issue, but I'm wondering if anyone knows what is going on. I have been running performance benchmarks for a Kafka 0.9 Consumer using a Kafka 0.9.0.0 (also tried 0.9.0.1) broker. At message sizes of 5k the broker becomes the bottleneck and throughput starts to become highly var

Consumer Group not visible for Kafka 0.9 Consumer

Hi all, I am having trouble getting details on a consumer group I am using. I would appreciate the help! Here is what I'm doing. *1. Launch a Kafka 0.9.0.1 and Consumer with group.id =testGroup* *2. I start receiving messages just fine. * *3. I can see my group in the 0.9.0.1 Bro

Re: Consumer Group not visible for Kafka 0.9 Consumer

/kafka-consumer-groups.sh? > > Thanks, > Liquan > > On Thu, Apr 14, 2016 at 2:01 PM, Alexander Cook wrote: > > > Hi all, > > > > I am having trouble getting details on a consumer group I am using. I > would > > appreciate the help! Here is what I'm doi

Detecting connection loss to Kafka Broker with 0.9 Clients

I am trying to detect connection loss in my Kafka 0.9 Consumer and Producer so that I can check if I should update any properties (update passwords or truststore locations by restarting the client with new configs if they have been provided). I am having trouble finding good ways to detect if I ha

Runtime JARs for 0.10 Producer and Consumer

Hi, This is slightly related to the "Jars in Kafka 0.10" thread. I am trying to figure out exactly which JARs I need at runtime for the 0.10 Kafka Producer and Kafka Consumer clients. Are the compile time dependencies and runtime dependencies documented anywhere I simply can't find? I know for su