I'm trying to figure out how to pragmatically read a consumer groups offset for 
a topic. 
What I'm trying to do is read the offsets of our DB consumers that run once an 
hour and batch lad all new messages. I then would have another consumer that 
monitors the offsets that have been consumed and consume the message not yet 
loaded storing them in  memory to be able to send them to a viewer. As messages 
get consumed they then get pruned from the in memory cache.

Basically I'm wanting to create window on the messages that haven't been loaded 
into the db.

I've seen ways of getting it from the command line but I'd like to from with in 
code.

Currently I'm using node-rdkafka.

I guess as a last resort I could shell the command line for the offsets then 
parse it and get it that way.


Ronald Fenner
Network Architect
Game Circus LLC.

rfen...@gamecircus.com

Reply via email to