[
https://issues.apache.org/jira/browse/SAMZA-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini resolved SAMZA-126.
-----------------------------------
Resolution: Fixed
Fix Version/s: 0.7.0
Merged and committed.
> 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
> Fix For: 0.7.0
>
> Attachments: SAMZA-126.0.patch
>
>
> 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)
