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
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
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,
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
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