Runtime JARs for 0.10 Producer and Consumer

2016-08-04 Thread Alexander Cook
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

Detecting connection loss to Kafka Broker with 0.9 Clients

2016-05-26 Thread Alexander Cook
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

Re: Consumer Group not visible for Kafka 0.9 Consumer

2016-04-15 Thread Alexander Cook
/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

Consumer Group not visible for Kafka 0.9 Consumer

2016-04-14 Thread Alexander Cook
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

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

2016-03-31 Thread Alexander Cook
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