Skip to content

Commit 8f69de9

Browse files
garyrussellartembilan
authored andcommitted
Polishing
1 parent 5155fca commit 8f69de9

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/reference/asciidoc/si-kafka.adoc

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ It provides the following components:
2222

2323
* The pollable `KafkaMessageSource` now implements `Pausable` so the consumer can be `paused` and `resumed`.
2424
You must continue to poll the adapter while paused, to avoid a topic/partition rebalance.
25+
See <<max-poll-records, the discussion about `max.poll.records`>> for more information.
2526
* XML configuration is now supported for the gateways and polled inbound channel adapter (in addition to the existing XML support for the other adapters).
2627
* The pollable message source can now be configured to fetch multiple records at-a-time.
2728

@@ -372,7 +373,8 @@ public KafkaMessageSource<String, String> source(ConsumerFactory<String, String>
372373

373374
Refer to the javadocs for available properties.
374375

375-
By default, `max.poll.records` must be 1; either explicitly set in the consumer factory, or it will be forced to 1 if the consumer factory is a `DefaultKafkaConsumerFactory`.
376+
[[max-poll-records]]
377+
By default, `max.poll.records` must be either explicitly set in the consumer factory, or it will be forced to 1 if the consumer factory is a `DefaultKafkaConsumerFactory`.
376378
Starting with versio 3.2, you can set the property `allowMultiFetch` to `true` to override this behavior.
377379

378380
IMPORTANT: You must poll the consumer within `max.poll.interval.ms` to avoid a rebalance.

0 commit comments

Comments
 (0)