Re: Reg: Callback on kafka metadata update

Can someone please help with the reply ? On Tue, Mar 21, 2017 at 2:53 PM, Sumit Maheshwari wrote: > Hi, > > I am looking for a callback that I can depend on to get notified when > kafka metadata changes. > For example: > >- Creation of new topic >- Addition o

Re: Common Identity between brokers

Can anyone answer the above query? On Mon, Mar 13, 2017 at 3:41 PM, Sumit Maheshwari wrote: > Hi, > > How can we identify if a set of brokers (nodes) belong to same cluster? > I understand we can use the zookeeper where all the brokers pointing to > same zookeeper URL's be

Common Identity between brokers

Hi, How can we identify if a set of brokers (nodes) belong to same cluster? I understand we can use the zookeeper where all the brokers pointing to same zookeeper URL's belong to same cluster. But is there a common identity between brokers which can help identify if brokers belong to same cluster?

Re: Reg: Reading consumer groups and lag

return anything? Thanks, Sumit On Wed, Feb 8, 2017 at 10:38 PM, R Krishna wrote: > You can run the same class executed in the scripts. > On Feb 8, 2017 8:50 AM, "Sumit Maheshwari" wrote: > > > Hi, > > > > Currently in 0.10 we can get the information abou

Reg: Reading consumer groups and lag

Hi, Currently in 0.10 we can get the information about the consumer groups and respective lag using the kafka-consumer-groups.sh. Is there a way to achieve the same programatically in java? Thanks, Sumit

Reg: Getting configuration properties for Kafka broker

Hi, To start the Kafka Broker from the CLI we run the following command: "*bin/kafka-server-start.sh config/server.properties"* How can I get hold of zookeeper configuration or all the configurations mentioned in server.properties in runtime. By runtime meaning code need to access those properti

Re: Reg: Need info on Kafka Brokers

jira/browse/KAFKA-2229 ) but not yet > in > > > > client APIs. Querying/listing topics request doesn't seem even to be > > > > planned yet. > > > > > > > > AdminUtils which talks with ZooKeeper via ZkClient is Kafka client > API > > &

Reg: Need info on Kafka Brokers

Hi, I am looking to get information about individual brokers in kafka cluster. The information that I am looking for is: - List of topics in a broker - Partitions for each topic in a broker - Metrics like BytesIn/Out Per min, Messages In/Min per topic - ... I have tried looking into