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
+3-1Lines changed: 3 additions & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -139,6 +139,7 @@ private KafkaAdmin admin;
139
139
----
140
140
====
141
141
142
+
[[sending-messages]]
142
143
==== Sending Messages
143
144
144
145
This section covers how to send messages.
@@ -726,6 +727,7 @@ IMPORTANT: The listener container for the replies MUST be configured with `AckMo
726
727
To avoid any possibility of losing messages, the template only commits offsets when there are zero requests outstanding, i.e. when the last outstanding request is released by the release strategy.
727
728
After a rebalance, it is possible for duplicate reply deliveries; these will be ignored for any in-flight requests; you may see error log messages when duplicate replies are received for already released replies.
728
729
730
+
[[receiving-messages]]
729
731
==== Receiving Messages
730
732
731
733
You can receive messages by configuring a `MessageListenerContainer` and providing a message listener or by using the `@KafkaListener` annotation.
@@ -828,7 +830,7 @@ The `ConcurrentMessageListenerContainer` delegates to one or more `KafkaMessageL
828
830
829
831
Starting with version 2.2.7, you can add a `RecordInterceptor` to the listener container; it will be invoked before calling the listener allowing inspection or modification of the record.
830
832
If the interceptor returns null, the listener is not called.
831
-
The interceptor is not invoked when the listener is a <<batch-listners, batch listener>>.
833
+
The interceptor is not invoked when the listener is a <<batch-listeners, batch listener>>.
832
834
833
835
Starting with version 2.3, the `CompositeRecordInterceptor` can be used to invoke multiple interceptors.
0 commit comments