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 wrote:
> kafka.javaapi.consumer.SimpleConsumer has an api to get the topic metadata.
>
> Thanks,
>
> Jun
>
>
There is no reason the ClientUtils.fetchTopicMetadata should take broker
instances, that is totally unusable. I have a patch for this included in
KAFKA-642.
-Jay
On Mon, Dec 3, 2012 at 7:53 AM, Chris Curtin wrote:
> Hi,
>
> I was able to implement my own lookup code but have a few concerns abo
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 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 Sc
Hi Jun,
Couldn't make either happen again with a clean start (removed all Kafka and
Zookeeper configuration and data files).
Thanks,
Chris
On Wed, Nov 28, 2012 at 12:12 PM, Chris Curtin wrote:
> Hi Jun,
>
> Sorry, neither the missing 0 leader or all those WARN messages have
> been reproducibl
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
Thanks
-- Prasanth
