Skip to content

Commit 0267f1a

Browse files
committed
SIK Docs for Send Timeout Change
1 parent 35bb022 commit 0267f1a

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/reference/asciidoc/si-kafka.adoc

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,10 @@ Flushing after sending several messages might be useful if you are using the `li
9393
By default, the expression looks for a `Boolean` value in the `KafkaIntegrationHeaders.FLUSH` header (`kafka_flush`).
9494
The flush will occur if the value is `true` and not if it's `false` or the header is absent.
9595

96+
Starting with version 3.3.1, the `KafkaProducerMessageHandler` `sendTimeoutExpression` default has changed from 10 seconds to the `delivery.timeout.ms` Kafka producer property `+ 5000` so that the actual Kafka error after a timeout is propagated to the application, instead of a timeout generated by this framework.
97+
This has been changed for consistency because you may get unexpected behavior (Spring may timeout the send, while it is actually, eventually, successful).
98+
IMPORTANT: That timeout is 120 seconds by default so you may wish to reduce it to get more timely failures.
99+
96100
===== Java Configuration
97101

98102
The following example shows how to configure the Kafka outbound channel adapter with Java:
@@ -445,6 +449,10 @@ If your code invokes the gateway behind a synchronous https://docs.spring.io/spr
445449
IMPORTANT: The gateway does not accept requests until the reply container has been assigned its topics and partitions.
446450
It is suggested that you add a `ConsumerRebalanceListener` to the template's reply container properties and wait for the `onPartitionsAssigned` call before sending messages to the gateway.
447451

452+
Starting with version 3.3.1, the `KafkaProducerMessageHandler` `sendTimeoutExpression` default has changed from 10 seconds to the `delivery.timeout.ms` Kafka producer property `+ 5000` so that the actual Kafka error after a timeout is propagated to the application, instead of a timeout generated by this framework.
453+
This has been changed for consistency because you may get unexpected behavior (Spring may timeout the send, while it is actually, eventually, successful).
454+
IMPORTANT: That timeout is 120 seconds by default so you may wish to reduce it to get more timely failures.
455+
448456
===== Java Configuration
449457

450458
The following example shows how to configure a gateway with Java:

0 commit comments

Comments
 (0)