Hi Jun,
Was trying out this last option or else would use the Simpleconsumer.
I am tryting to set the offset of my choice using
getZkClinet().createPersistent("/consumers/test_group/offsets/golf4/0-0",
"22274");
or
ZkUtils.updatePersistentPath(getZkClinet(),"/consumers/test_group/offsets/golf
Thanks Jun
On Wed, Sep 12, 2012 at 6:10 AM, Jun Rao wrote:
> You can try the 0.8 branch. The basic functionality is there. It's still
> under testing/development though.
>
> Thanks,
>
> Jun
>
> On Tue, Sep 11, 2012 at 11:12 PM, Neelesh wrote:
>
> > Hi,
> > We are finally implementing kafka fo
You need to build it.
./sbt update
./sbt package
Thanks,
Jun
On Wed, Sep 12, 2012 at 12:29 AM, 司开剑 wrote:
> I download the kafka from the website. But I can't find the jar called
> "kafka-0.7.1.jar" whick I saw from my colleague. I want to lenrn the source
> code.
>
> --
> To Be A Better Man!
You can try the 0.8 branch. The basic functionality is there. It's still
under testing/development though.
Thanks,
Jun
On Tue, Sep 11, 2012 at 11:12 PM, Neelesh wrote:
> Hi,
> We are finally implementing kafka for some use cases at our org. I
> wanted to know if there is a reasonably stable
I download the kafka from the website. But I can't find the jar called
"kafka-0.7.1.jar" whick I saw from my colleague. I want to lenrn the source
code.
--
To Be A Better Man!
Hi !
--
To Be A Better Man!