Thanks Jun,
I completely missed your earlier reply in this thread. Changing to use the
javaapi makes the process a lot cleaner.
Thanks,
Chris
On Mon, Dec 3, 2012 at 11:26 AM, Jun Rao <junrao@gmail.com> wrote:
> kafka.javaapi.consumer.SimpleConsumer has an api to get the topic metadata.
>
> Thanks,
>
> Jun
>
> On Mon, Dec 3, 2012 at 7:53 AM, Chris Curtin <curtin.chris@gmail.com>
> wrote:
>
> > Hi,
> >
> > I was able to implement my own lookup code but have a few concerns about
> > this long term:
> > - the Broker class is marked as 'private' in the Scala code. IntelliJ
> gives
> > me an error about using it, but the runtime lets me use it and get the
> > host/port out.
> > - I have to know a lot about the structure of some internal classes for
> > this to work, so changes in the implementation would cause my logic to
> > break.
> >
> > I did a quick JIRA search and didn't see a request for a java-api for
> > finding the primary, is that already on the roadmap or should I submit
> > an enhancement request?
> >
> > Thanks,
> >
> > Chris
> >
> >
> > On Wed, Nov 28, 2012 at 2:08 PM, Neha Narkhede <neha.narkhede@gmail.com
> > >wrote:
> >
> > > <snip>
> > >
> > > Also, there are 2 ways to send the topic metadata request. One way is
> > > how SimpleConsumerShell.scala uses ClientUtils.fetchTopicMetadata().
> > > Another way is by using the send() API on SyncProducer.
> > >
> > > Thanks,
> > > Neha
> > >
> > >
> >
>
|