Re: still looking for Maven POM for Java Kafka

2014-05-06 Thread Steven A Robenalt
Hi Dave, Here's a POM I use to build the examples. It's pretty simple, including kafka 0.8.0 with scala 2.9.2 libs, and targeting Java 7. I also made a couple of mods to make things easier: 1) I use log4j 1.2.17 to eliminate a log4j 1.2.15 dependency on the sun jdmk. 2) I use the maven dependency

Re: Storm Kafka spout

2014-04-23 Thread Steven A Robenalt
Good to know. I was looking at the former - will check out the latter. On Wed, Apr 23, 2014 at 4:41 PM, Joe Stein wrote: > Folks have been using this spout > https://github.com/wurstmeister/storm-kafka-0.8-plus which has now been > merged into the storm incubating project > https://github.com/a

Re: Migration Tool consumer rebalance error when attempting to migrate from Kafka 0.7 to Kafka 0.8

2014-03-19 Thread Steven A Robenalt
Hi Mo, Is the broker id in your server properties really the same for all 3, or is that a typo? Steve On Wed, Mar 19, 2014 at 8:10 AM, Jun Rao wrote: > Were there any logging before that? There should be some logging that tells > you why the rebalance failed. > > Thanks, > > Jun > > > On Wed,

Re: Request Kafka / ZooKeeper JMS details

2014-03-17 Thread Steven A Robenalt
Hi Arun, Kafka doesn't provide JMS services. It has some architectural similarities with JMS, though Kafka is designed to scale to much larger systems than JMS, but if your app uses JMS, it will need to be modified to use Kafka Producers and Consumers in order to work. Steve On Mon, Mar 17, 20

Re: Consumer group ID for high level consumer

2014-02-24 Thread Steven A Robenalt
Hi Binita, When you use a group id with a high level consumer, the messages will be distributed among all consumers sharing the same group. So if you have 3 consumers sharing the same group, each will process 1/3 of the messages within the group. By contrast, if each of the same 3 consumers used a