Skip to content

Commit ed0f2e5

Browse files
garyrussellartembilan
authored andcommitted
Update What's new For RC1
1 parent b88cbf9 commit ed0f2e5

File tree

2 files changed

+27
-0
lines changed

2 files changed

+27
-0
lines changed

spring-kafka-docs/src/main/asciidoc/kafka.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,6 +1047,8 @@ The `CompositeRecordInterceptor` and `CompositeBatchInterceptor` can be used to
10471047

10481048
By default, starting with version 2.8, when using transactions, the interceptor is invoked before the transaction has started.
10491049
You can set the listener container's `interceptBeforeTx` property to `false` to invoke the interceptor after the transaction has started instead.
1050+
Starting with version 2.9, this will apply to any transaction manager, not just `KafkaAwareTransactionManager` s.
1051+
This allows, for example, the interceptor to participate in a JDBC transaction started by the container.
10501052

10511053
Starting with versions 2.3.8, 2.4.6, the `ConcurrentMessageListenerContainer` now supports https://kafka.apache.org/documentation/#static_membership[Static Membership] when the concurrency is greater than one.
10521054
The `group.instance.id` is suffixed with `-n` with `n` starting at `1`.

spring-kafka-docs/src/main/asciidoc/whats-new.adoc

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,3 +16,28 @@ See <<default-eh>> for more information.
1616

1717
The `DefaultErrorHandler` now has a `BackOffHandler` property.
1818
See <<backoff-handlers>> for more information.
19+
20+
[[x29-lc-changes]]
21+
==== Listener Container Changes
22+
23+
`interceptBeforeTx` now works with all transaction managers (previously it was only applied when a `KafkaAwareTransactionManager` was used).
24+
See <<interceptBeforeTX>>.
25+
26+
A new container property `pauseImmediate` is provided which allows the container to pause the consumer after the current record is processed, instead of after all the records from the previous poll have been processed.
27+
See <<pauseImmediate>>.
28+
29+
Events related to consumer authentication and authorization
30+
31+
[[x29-hm-changes]]
32+
==== Header Mapper Changes
33+
34+
You can now configure which inbound headers should be mapped.
35+
Also available in version 2.8.8 or later.
36+
See <<headers>> for more information.
37+
38+
[[x29-rkt-changes]]
39+
==== `ReplyingKafkaTemplate` Changes
40+
41+
The template now provides a method to wait for assignment on the reply container, to avoid a race when sending a request before the reply container is initialized.
42+
Also available in version 2.8.8 or later.
43+
See <<replying-template>>.

0 commit comments

Comments
 (0)