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/changes-since-1.0.adoc
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -48,7 +48,7 @@ When a replying listener returns an `Iterable` this property controls whether th
48
48
See <<annotation-send-to>> for more information
49
49
50
50
Batch listeners can now be configured with a `BatchToRecordAdapter`; this allows, for example, the batch to be processed in a transaction while the listener gets one record at a time.
51
-
With the default implementation, a `ConsumerRecordRecoverer` can be used to handle errors within the batch, without aborting the entire batch - this might be useful when using transactions.
51
+
With the default implementation, a `ConsumerRecordRecoverer` can be used to handle errors within the batch, without stopping the processing of the entire batch - this might be useful when using transactions.
52
52
See <<transactions-batch>> for more information.
53
53
54
54
==== Kafka Streams
@@ -239,7 +239,7 @@ See <<container-factory>> for more information.
239
239
A new container property (`missingTopicsFatal`) has been added.
240
240
See <<kafka-container>> for more information.
241
241
242
-
A `ConsumerStoppedEvent` is now emitted when a consumer terminates.
242
+
A `ConsumerStoppedEvent` is now emitted when a consumer stops.
243
243
See <<thread-safety>> for more information.
244
244
245
245
Batch listeners can optionally receive the complete `ConsumerRecords<?, ?>` object instead of a `List<ConsumerRecord<?, ?>`.
Copy file name to clipboardExpand all lines: src/reference/asciidoc/kafka.adoc
+3-3Lines changed: 3 additions & 3 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -2439,7 +2439,7 @@ An error message is also logged when this condition occurs.
2439
2439
* `ConsumerStoppingEvent`: published by each consumer just before stopping.
2440
2440
* `ConsumerStoppedEvent`: published after the consumer is closed.
2441
2441
See <<thread-safety>>.
2442
-
* `ContainerStoppedEvent`: published when all consumers have terminated.
2442
+
* `ContainerStoppedEvent`: published when all consumers have stopped.
2443
2443
2444
2444
IMPORTANT: By default, the application context's event multicaster invokes event listeners on the calling thread.
2445
2445
If you change the multicaster to use an async executor, you must not invoke any `Consumer` methods when the event contains a reference to the consumer.
@@ -2533,7 +2533,7 @@ To solve this issue, the container publishes a `NonResponsiveConsumerEvent` if a
2533
2533
By default, this check is performed once every 30 seconds in each container.
2534
2534
You can modify this behavior by setting the `monitorInterval` (default 30 seconds) and `noPollThreshold` (default 3.0) properties in the `ContainerProperties` when configuring the listener container.
2535
2535
The `noPollThreshold` should be greater than `1.0` to avoid getting spurious events due to a race condition.
2536
-
Receiving such an event lets you stop the containers, thus waking the consumer so that it can terminate.
2536
+
Receiving such an event lets you stop the containers, thus waking the consumer so that it can stop.
2537
2537
2538
2538
====== Event Consumption
2539
2539
@@ -3120,7 +3120,7 @@ See <<after-rollback>> for more information.
3120
3120
3121
3121
When using a batch listener, version 2.4.2 introduced an alternative mechanism to deal with failures while processing a batch; the `BatchToRecordAdapter`.
3122
3122
When a container factory with `batchListener` set to true is configured with a `BatchToRecordAdapter`, the listener is invoked with one record at a time.
3123
-
This enables error handling within the batch, while still allowing to abort the entire batch, depending on the exception type.
3123
+
This enables error handling within the batch, while still making it possible to stop processing the entire batch, depending on the exception type.
3124
3124
A default `BatchToRecordAdapter` is provided, that can be configured with a standard `ConsumerRecordRecoverer` such as the `DeadLetterPublishingRecoverer`.
3125
3125
The following test case configuration snippet illustrates how to use this feature:
0 commit comments