Hi - I am making a few assumptions about the 0.8 high-level consumer API that I 
am looking to confirm:

-it is OK to have multiple ConsumerConnector objects in the same process? To be 
sure, they are all operating independently. I could probably shove everything 
into one ConsumerConnector if I had to but its easier to manage with separate 
objects and I have enough memory. Anyone aware of any gotchas with this? I 
haven't seen any issues with this so far but my testing hasn't been exhaustive 
(2 or 3 at at time).

-is it OK to call ConsumerConnector.shutdown() whenever I want? In other words, 
if I find out that a downstream process has failed, can I just call 
ConsumerConnector.shutdown() at that moment (from another thread) or do I need 
to wait until the next ConsumerTimeout and call shutdown then? I haven't had a 
chance to test this yet but based on my understanding of how the consumer 
works, it seems like it should be OK. I am hoping that I can call shutdown() at 
anytime and that it will unblock any blocking calls.

Thanks,
Paul

Reply via email to