Major Description
When I put a Thread.sleep(1000) in my process() method, I noticed that the reads metric in BrokerProxy:
metrics.brokerReads(host, port).inc
Is still be incremented thousands of times a second. This is unexpected, since I should only be processing 1 message a second, and therefore not be fetching until the message buffer for my input stream is empty, again.
Upon investigation, I found that fetchMessage will call simpleConsumer.fetch, even if the fetch request being issued has no topic partitions in it.