Skip to content
This repository has been archived by the owner on Mar 30, 2023. It is now read-only.

Allow max.poll.records > 1 #267

Closed
garyrussell opened this issue Apr 17, 2019 · 0 comments · Fixed by #268
Closed

Allow max.poll.records > 1 #267

garyrussell opened this issue Apr 17, 2019 · 0 comments · Fixed by #268
Assignees
Milestone

Comments

@garyrussell
Copy link
Contributor

garyrussell commented Apr 17, 2019

Add a flag to allow fetching multiple records and iterate over them in receive().

Users must be sure to poll at a sufficient rate to consume all records within max.poll.interval.ms to avoid a rebalance.

Include remainingRecords header.

@garyrussell garyrussell self-assigned this Apr 17, 2019
@garyrussell garyrussell added this to the 3.2.M2 milestone Apr 17, 2019
garyrussell added a commit to garyrussell/spring-integration-kafka that referenced this issue Apr 17, 2019
Resolves spring-attic#267

- add an option to allow fetching multiple records per poll
artembilan pushed a commit that referenced this issue Apr 17, 2019
Resolves #267

- add an option to allow fetching multiple records per poll

* DSL for new constructor arg
garyrussell added a commit to garyrussell/spring-integration that referenced this issue Jun 24, 2020
Resolves spring-attic/spring-integration-kafka#267

- add an option to allow fetching multiple records per poll

* DSL for new constructor arg
artembilan pushed a commit to spring-projects/spring-integration that referenced this issue Jun 25, 2020
Resolves spring-attic/spring-integration-kafka#267

- add an option to allow fetching multiple records per poll

* DSL for new constructor arg
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Development

Successfully merging a pull request may close this issue.

1 participant