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
Copy file name to clipboardExpand all lines: src/reference/asciidoc/kafka.adoc
+5
Original file line number
Diff line number
Diff line change
@@ -93,6 +93,7 @@ The `KafkaProducerMessageHandler.sendTimeoutExpression` default has changed from
93
93
This has been changed for consistency because you may get unexpected behavior (Spring may timeout the send, while it is actually, eventually, successful).
94
94
IMPORTANT: That timeout is 120 seconds by default so you may wish to reduce it to get more timely failures.
95
95
96
+
[[kakfa-outbound-adapter-coniguration]]
96
97
==== Configuration
97
98
98
99
The following example shows how to configure the outbound channel adapter for Apache Kafka:
@@ -227,6 +228,7 @@ By default, a `RawRecordHeaderErrorMessageStrategy` is used, to provide access t
227
228
IMPORTANT: This form of retry is blocking and could cause a rebalance if the aggregate retry delays across all polled records might exceed the `{@code `max.poll.interval.ms` consumer property.
228
229
Instead, consider adding a `DefaultErrorHandler` to the listener container, configured with a `KafkaErrorSendingMessageRecoverer`.
229
230
231
+
[[kafka-inbound-adapter-configuration]]
230
232
==== Configuration
231
233
232
234
The following example shows how to configure a message-driven channel adapter:
@@ -349,6 +351,7 @@ If the adapter does not have an `id` property, the container's bean name is the
349
351
350
352
The `KafkaMessageSource` provides a pollable channel adapter implementation.
351
353
354
+
[[kafka-message-source-configuration]]
352
355
==== Configuration
353
356
354
357
====
@@ -421,6 +424,7 @@ The `KafkaProducerMessageHandler` `sendTimeoutExpression` default is `delivery.t
421
424
This has been changed for consistency because you may get unexpected behavior (Spring may timeout the `send()`, while it is actually, eventually, successful).
422
425
IMPORTANT: That timeout is 120 seconds by default so you may wish to reduce it to get more timely failures.
423
426
427
+
[[kafka-outbound-gateway-configuration]]
424
428
==== Configuration
425
429
426
430
The following example shows how to configure a gateway:
@@ -507,6 +511,7 @@ public IntegrationFlow outboundGateFlow() {
507
511
508
512
The inbound gateway is for request/reply operations.
509
513
514
+
[[kafka-inbound-gateway-configurartion]]
510
515
==== Configuration
511
516
512
517
The following example shows how to configure an inbound gateway:
0 commit comments