Hi all,

In case you are interested here is my presentation on Kafka and Storm. It
also describes how we are using Kafka and Storm together.

http://www.ustream.tv/recorded/24877591

It describes our Kafka cluster (a small one) and our usecases. Also
introduces Kafka and Storm.

The initial company introduction is fast forwarded.

Regards,
Vaibhav
GumGum
Santa Monica

Vaibhav,

Thanks for sharing this. Could you add the link to the presentation section
in our wiki?

Jun

On Thu, Aug 23, 2012 at 11:27 AM, Vaibhav Puranik <[EMAIL PROTECTED]>wrote:

> Hi all,
>
> In case you are interested here is my presentation on Kafka and Storm. It
> also describes how we are using Kafka and Storm together.
>
> http://www.ustream.tv/recorded/24877591
>
> It describes our Kafka cluster (a small one) and our usecases. Also
> introduces Kafka and Storm.
>
> The initial company introduction is fast forwarded.
>
> Regards,
> Vaibhav
> GumGum
> Santa Monica
>

Thanks Jun. It's done.

Regards,
Vaibhav

On Fri, Aug 24, 2012 at 6:44 AM, Jun Rao <[EMAIL PROTECTED]> wrote:

> Vaibhav,
>
> Thanks for sharing this. Could you add the link to the presentation section
> in our wiki?
>
> Jun
>
> On Thu, Aug 23, 2012 at 11:27 AM, Vaibhav Puranik <[EMAIL PROTECTED]
> >wrote:
>
> > Hi all,
> >
> > In case you are interested here is my presentation on Kafka and Storm. It
> > also describes how we are using Kafka and Storm together.
> >
> > http://www.ustream.tv/recorded/24877591
> >
> > It describes our Kafka cluster (a small one) and our usecases. Also
> > introduces Kafka and Storm.
> >
> > The initial company introduction is fast forwarded.
> >
> > Regards,
> > Vaibhav
> > GumGum
> > Santa Monica
> >
>

Thanks for sharing this presentation.  It's awesome.  You mentioned that
you have created your own version of SimpleKafkaSpout.  Was that because
the KafkaSpout didnt' work for you?

For the past couple of days I have been trying to get KakfaSpout, Tridents
Transactional & Opaque Kafka Spouts to work but haven't had any luck.

Care to share your SimpleKafkaSpout ;)  I am assuming it works with
kafka-0.7.1-incubating & storm 0.8.0, correct?

Here's how I am using the KafkaSpout:

        SpoutConfig spoutConfig SpoutConfig.fromHostStrings(ImmutableList.of("localhost:2181"), 1, "test",
"/foo", "foo");
        spoutConfig.zkServers = ImmutableList.of("localhost");
        spoutConfig.zkPort = 2181;
        spoutConfig.scheme = new StringScheme();
        spoutConfig.forceStartOffsetTime(-2);
        builder.setSpout("spout", new KafkaSpout(spoutConfig), 5);

Do you see anything wrong with this?

Thanks again for sharing your preso.
On Fri, Aug 24, 2012 at 9:25 AM, Vaibhav Puranik <[EMAIL PROTECTED]> wrote:

> Thanks Jun. It's done.
>
> Regards,
> Vaibhav
>
> On Fri, Aug 24, 2012 at 6:44 AM, Jun Rao <[EMAIL PROTECTED]> wrote:
>
> > Vaibhav,
> >
> > Thanks for sharing this. Could you add the link to the presentation
> section
> > in our wiki?
> >
> > Jun
> >
> > On Thu, Aug 23, 2012 at 11:27 AM, Vaibhav Puranik <[EMAIL PROTECTED]
> > >wrote:
> >
> > > Hi all,
> > >
> > > In case you are interested here is my presentation on Kafka and Storm.
> It
> > > also describes how we are using Kafka and Storm together.
> > >
> > > http://www.ustream.tv/recorded/24877591
> > >
> > > It describes our Kafka cluster (a small one) and our usecases. Also
> > > introduces Kafka and Storm.
> > >
> > > The initial company introduction is fast forwarded.
> > >
> > > Regards,
> > > Vaibhav
> > > GumGum
> > > Santa Monica
> > >
> >
>

Hold off on this for now :)  It started working after I changed it to:

SpoutConfig.fromHostStrings(ImmutableList.of("localhost:*9092*"), 1,
"test", "/foo", "foo");

On Sat, Aug 25, 2012 at 11:06 AM, Something Something <
[EMAIL PROTECTED]> wrote:

> Thanks for sharing this presentation.  It's awesome.  You mentioned that
> you have created your own version of SimpleKafkaSpout.  Was that because
> the KafkaSpout didnt' work for you?
>
> For the past couple of days I have been trying to get KakfaSpout, Tridents
> Transactional & Opaque Kafka Spouts to work but haven't had any luck.
>
> Care to share your SimpleKafkaSpout ;)  I am assuming it works with
> kafka-0.7.1-incubating & storm 0.8.0, correct?
>
> Here's how I am using the KafkaSpout:
>
>         SpoutConfig spoutConfig > SpoutConfig.fromHostStrings(ImmutableList.of("localhost:2181"), 1, "test",
> "/foo", "foo");
>         spoutConfig.zkServers = ImmutableList.of("localhost");
>         spoutConfig.zkPort = 2181;
>         spoutConfig.scheme = new StringScheme();
>         spoutConfig.forceStartOffsetTime(-2);
>         builder.setSpout("spout", new KafkaSpout(spoutConfig), 5);
>
> Do you see anything wrong with this?
>
> Thanks again for sharing your preso.
>
>
>
> On Fri, Aug 24, 2012 at 9:25 AM, Vaibhav Puranik <[EMAIL PROTECTED]>wrote:
>
>> Thanks Jun. It's done.
>>
>> Regards,
>> Vaibhav
>>
>> On Fri, Aug 24, 2012 at 6:44 AM, Jun Rao <[EMAIL PROTECTED]> wrote:
>>
>> > Vaibhav,
>> >
>> > Thanks for sharing this. Could you add the link to the presentation
>> section
>> > in our wiki?
>> >
>> > Jun
>> >
>> > On Thu, Aug 23, 2012 at 11:27 AM, Vaibhav Puranik <[EMAIL PROTECTED]
>> > >wrote:
>> >
>> > > Hi all,
>> > >
>> > > In case you are interested here is my presentation on Kafka and
>> Storm. It
>> > > also describes how we are using Kafka and Storm together.
>> > >
>> > > http://www.ustream.tv/recorded/24877591
>> > >
>> > > It describes our Kafka cluster (a small one) and our usecases. Also
>> > > introduces Kafka and Storm.
>> > >
>> > > The initial company introduction is fast forwarded.
>> > >
>> > > Regards,
>> > > Vaibhav
>> > > GumGum
>> > > Santa Monica
>> > >
>> >
>>
>
>