[
https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062811#comment-15062811
]
Jason Gustafson commented on KAFKA-3007:
----------------------------------------
[~aartigupta] We've been talking on the user list about adding a feature to set
the maximum number of messages returned in a call to poll(). This could either
be a second argument to poll() or a configuration option. The main problem this
addresses is that some use cases need finer control over how many messages are
returned in order to set an appropriate session timeout. We should have a KIP
for this relatively soon.
> new Consumer should expose mechanism to fetch single message
> -------------------------------------------------------------
>
> Key: KAFKA-3007
> URL: https://issues.apache.org/jira/browse/KAFKA-3007
> Project: Kafka
> Issue Type: Improvement
> Components: consumer
> Affects Versions: 0.9.0.0
> Reporter: aarti gupta
> Assignee: Neha Narkhede
>
> Currently, the consumer.poll(timeout)
> returns all messages that have not been acked since the last fetch
> The only way to process a single message, is to throw away all but the first
> message in the list
> This would mean we are required to fetch all messages into memory, and this
> coupled with the client being not thread-safe, (i.e. we cannot use a
> different thread to ack messages, makes it hard to consume messages when the
> order of message arrival is important, and a large number of messages are
> pending to be consumed)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
