Closed garyrussell closed 5 years ago
Add a flag to allow fetching multiple records and iterate over them in receive().
receive()
Users must be sure to poll at a sufficient rate to consume all records within max.poll.interval.ms to avoid a rebalance.
max.poll.interval.ms
Include remainingRecords header.
remainingRecords
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.msto avoid a rebalance.Include
remainingRecordsheader.