darion yaphet created STORM-2001:
------------------------------------
Summary: New Kafka Spout Consume Max Records
Key: STORM-2001
URL: https://issues.apache.org/jira/browse/STORM-2001
Project: Apache Storm
Issue Type: New Feature
Components: storm-kafka
Affects Versions: 1.0.0, 1.0.1
Reporter: darion yaphet
Assignee: darion yaphet
Kafka 0.10 have add a new parameter (max.poll.records) that use to control the
number of messages returned in a single call to poll(). It's useful to control
topology QPS .
[Implement max.poll.records for new consumer
(KIP-41)|https://issues.apache.org/jira/browse/KAFKA-3007]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)