You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
@@ -373,7 +394,7 @@ Refer to the javadocs for available properties.
373
394
374
395
[[max-poll-records]]
375
396
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`.
376
-
Starting with version 3.2, you can set the property `allowMultiFetch` to `true` to override this behavior.
397
+
You can set the property `allowMultiFetch` to `true` to override this behavior.
377
398
378
399
IMPORTANT: You must poll the consumer within `max.poll.interval.ms` to avoid a rebalance.
379
400
If you set `allowMultiFetch` to `true` you must process all the retrieved records, and poll again, within `max.poll.interval.ms`.
@@ -663,7 +684,7 @@ public IntegrationFlow flowWithPollable(KafkaTemplate<Integer, String> template,
@@ -177,38 +177,37 @@ To change this behavior and receive a `Multipart` object payload, set `embeddedP
177
177
For content types that are unknown to the `DataHandler`, the contents are rendered as a `byte[]` with a `contentType` header of `application/octet-stream`.
178
178
179
179
When you do not provide a header mapper, the message payload is the `MimeMessage` presented by `javax.mail`.
180
-
The framework provides a `MailToStringTransformer` that you can use to convert the message by using a strategy to convert the mail contents to a `String`.
181
-
This is also available by using the XML namespace, as the following example shows:
180
+
The framework provides a `MailToStringTransformer` that you can use to convert the message by using a strategy to convert the mail contents to a `String`:
182
181
183
182
====
184
-
[source, xml]
183
+
[source, java, role="primary"]
184
+
.Java DSL
185
185
----
186
-
<int-mail:mail-to-string-transformer ... >
186
+
...
187
+
.transform(Mail.toStringTransformer())
188
+
...
187
189
----
188
-
====
189
-
190
-
The following example does the same thing with Java configuration:
Alternatively, you can provide your own implementation of the `MetadataStore` interface (for example,
36
-
`JdbcMetadataStore`) and configure it as a bean in the application context.
35
+
Alternatively, you can provide your own implementation of the `MetadataStore` interface (for example, `JdbcMetadataStore`) and configure it as a bean in the application context.
37
36
38
37
Starting with version 4.0, `SimpleMetadataStore`, `PropertiesPersistingMetadataStore`, and `RedisMetadataStore` implement `ConcurrentMetadataStore`.
39
38
These provide for atomic updates and can be used across multiple component or application instances.
0 commit comments