Chris Riccomini created SAMZA-126:
-------------------------------------
Summary: BrokerProxy calls SimpleConsumer.fetch with empty request
Key: SAMZA-126
URL: https://issues.apache.org/jira/browse/SAMZA-126
Project: Samza
Issue Type: Bug
Components: kafka
Affects Versions: 0.6.0
Reporter: Chris Riccomini
Assignee: Chris Riccomini
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.
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
