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
The document contains words written in plural form, so I think we can avoid the plural form by using double back-ticks instead of spaces.
Signed-off-by: Tran Ngoc Nhan <[email protected]>
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/antora/modules/ROOT/pages/appendix/change-history.adoc
+19-19
Original file line number
Diff line number
Diff line change
@@ -320,14 +320,14 @@ See xref:kafka/container-props.adoc[Listener Container Properties] for more info
320
320
[[x30-template-changes]]
321
321
=== `KafkaTemplate` Changes
322
322
323
-
The futures returned by this class are now `CompletableFuture`s instead of `ListenableFuture`s.
323
+
The futures returned by this class are now ``CompletableFuture``s instead of ``ListenableFuture``s.
324
324
See xref:kafka/sending-messages.adoc#kafka-template[Using `KafkaTemplate`].
325
325
326
326
[[x30-rkt-changes]]
327
327
=== `ReplyingKafkaTemplate` Changes
328
328
329
-
The futures returned by this class are now `CompletableFuture`s instead of `ListenableFuture`s.
330
-
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`] and xref:kafka/sending-messages.adoc#exchanging-messages[Request/Reply with `Message<?>`s].
329
+
The futures returned by this class are now ``CompletableFuture``s instead of ``ListenableFuture``s.
330
+
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`] and xref:kafka/sending-messages.adoc#exchanging-messages[Request/Reply with ``Message<?>``s].
331
331
332
332
[[x30-listener]]
333
333
=== `@KafkaListener` Changes
@@ -395,7 +395,7 @@ See xref:kafka/headers.adoc[Message Headers] for more information.
395
395
[[x29-template-changes]]
396
396
=== `KafkaTemplate` Changes
397
397
398
-
In 3.0, the futures returned by this class will be `CompletableFuture`s instead of `ListenableFuture`s.
398
+
In 3.0, the futures returned by this class will be ``CompletableFuture``s instead of ``ListenableFuture``s.
399
399
See xref:kafka/sending-messages.adoc#kafka-template[Using `KafkaTemplate`] for assistance in transitioning when using this release.
400
400
401
401
[[x29-rkt-changes]]
@@ -405,8 +405,8 @@ The template now provides a method to wait for assignment on the reply container
405
405
Also available in version 2.8.8 or later.
406
406
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`].
407
407
408
-
In 3.0, the futures returned by this class will be `CompletableFuture`s instead of `ListenableFuture`s.
409
-
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`] and xref:kafka/sending-messages.adoc#exchanging-messages[Request/Reply with `Message<?>`s] for assistance in transitioning when using this release.
408
+
In 3.0, the futures returned by this class will be ``CompletableFuture``s instead of ``ListenableFuture``s.
409
+
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`] and xref:kafka/sending-messages.adoc#exchanging-messages[Request/Reply with ``Message<?>``s] for assistance in transitioning when using this release.
410
410
411
411
[[what-s-new-in-2-8-since-2-7]]
412
412
== What's New in 2.8 Since 2.7
@@ -474,7 +474,7 @@ See xref:kafka/annotation-error-handling.adoc#error-handlers[Container Error Han
474
474
475
475
The `interceptBeforeTx` container property is now `true` by default.
476
476
477
-
The `authorizationExceptionRetryInterval` property has been renamed to `authExceptionRetryInterval` and now applies to `AuthenticationException`s in addition to `AuthorizationException`s previously.
477
+
The `authorizationExceptionRetryInterval` property has been renamed to `authExceptionRetryInterval` and now applies to ``AuthenticationException``s in addition to ``AuthorizationException``s previously.
478
478
Both exceptions are considered fatal and the container will stop by default, unless this property is set.
479
479
480
480
See xref:kafka/receiving-messages/message-listener-container.adoc#kafka-container[Using `KafkaMessageListenerContainer`] and xref:kafka/container-props.adoc[Listener Container Properties] for more information.
@@ -537,7 +537,7 @@ See xref:kafka/container-props.adoc[Listener Container Properties] for more info
537
537
538
538
Error handlers that use a `BackOff` between delivery attempts (e.g. `SeekToCurrentErrorHandler` and `DefaultAfterRollbackProcessor`) will now exit the back off interval soon after the container is stopped, rather than delaying the stop.
539
539
540
-
Error handlers and after rollback processors that extend `FailedRecordProcessor` can now be configured with one or more `RetryListener`s to receive information about retry and recovery progress.
540
+
Error handlers and after rollback processors that extend `FailedRecordProcessor` can now be configured with one or more ``RetryListener``s to receive information about retry and recovery progress.
541
541
542
542
The `RecordInterceptor` now has additional methods called after the listener returns (normally, or by throwing an exception).
543
543
It also has a sub-interface `ConsumerAwareRecordInterceptor`.
@@ -578,7 +578,7 @@ See xref:kafka/transactions.adoc[Transactions] for more information.
578
578
579
579
There is now a mechanism to examine a reply and fail the future exceptionally if some condition exists.
580
580
581
-
Support for sending and receiving `spring-messaging` `Message<?>`s has been added.
581
+
Support for sending and receiving `spring-messaging` ``Message<?>``s has been added.
582
582
583
583
See xref:kafka/sending-messages.adoc#replying-template[Using `ReplyingKafkaTemplate`] for more information.
584
584
@@ -602,9 +602,9 @@ It is now possible to add a `spring-messaging` `SmartMessageConverter` to the `M
602
602
See xref:kafka/serdes.adoc#messaging-message-conversion[Spring Messaging Message Conversion] for more information.
603
603
604
604
[[x27-sequencing]]
605
-
=== Sequencing `@KafkaListener`s
605
+
=== Sequencing ``@KafkaListener``s
606
606
607
-
See xref:kafka/receiving-messages/sequencing.adoc[Starting `@KafkaListener`s in Sequence] for more information.
607
+
See xref:kafka/receiving-messages/sequencing.adoc[Starting ``@KafkaListener``s in Sequence] for more information.
608
608
609
609
[[x27-exp-backoff]]
610
610
=== `ExponentialBackOffWithMaxRetries`
@@ -638,7 +638,7 @@ In addition, you can now select the `BackOff` to use based on the failed record
638
638
You can now configure an `adviceChain` in the container properties.
639
639
See xref:kafka/container-props.adoc[Listener Container Properties] for more information.
640
640
641
-
When the container is configured to publish `ListenerContainerIdleEvent`s, it now publishes a `ListenerContainerNoLongerIdleEvent` when a record is received after publishing an idle event.
641
+
When the container is configured to publish ``ListenerContainerIdleEvent``s, it now publishes a `ListenerContainerNoLongerIdleEvent` when a record is received after publishing an idle event.
642
642
See xref:kafka/events.adoc[Application Events] and xref:kafka/events.adoc#idle-containers[Detecting Idle and Non-Responsive Consumers] for more information.
643
643
644
644
[[kafkalistener-changes]]
@@ -742,7 +742,7 @@ See xref:kafka/annotation-error-handling.adoc#error-handlers[Container Error Han
742
742
The `getAssignmentsByClientId()` method has been added, making it easier to determine which consumers in a concurrent container are assigned which partition(s).
743
743
See xref:kafka/container-props.adoc[Listener Container Properties] for more information.
744
744
745
-
You can now suppress logging entire `ConsumerRecord`s in error, debug logs etc.
745
+
You can now suppress logging entire ``ConsumerRecord``s in error, debug logs etc.
746
746
See `onlyLogRecordMetadata` in xref:kafka/container-props.adoc[Listener Container Properties].
747
747
748
748
[[x25-template]]
@@ -763,7 +763,7 @@ See xref:kafka/sending-messages.adoc#kafka-template[Using `KafkaTemplate`] for m
763
763
[[x25-string-serializer]]
764
764
=== Kafka String Serializer/Deserializer
765
765
766
-
New `ToStringSerializer`/`StringDeserializer`s as well as an associated `SerDe` are now provided.
766
+
New `ToStringSerializer`/``StringDeserializer``s as well as an associated `SerDe` are now provided.
767
767
See xref:kafka/serdes.adoc#string-serde[String serialization] for more information.
768
768
769
769
[[x25-json-deser]]
@@ -886,8 +886,8 @@ See xref:kafka/receiving-messages/message-listener-container.adoc#kafka-containe
886
886
[[cb-2-2-and-2-3-listener-container-changes]]
887
887
=== Listener Container Changes
888
888
889
-
Previously, error handlers received `ListenerExecutionFailedException` (with the actual listener exception as the `cause`) when the listener was invoked using a listener adapter (such as `@KafkaListener`s).
890
-
Exceptions thrown by native `GenericMessageListener`s were passed to the error handler unchanged.
889
+
Previously, error handlers received `ListenerExecutionFailedException` (with the actual listener exception as the `cause`) when the listener was invoked using a listener adapter (such as ``@KafkaListener``s).
890
+
Exceptions thrown by native ``GenericMessageListener``s were passed to the error handler unchanged.
891
891
Now a `ListenerExecutionFailedException` is always the argument (with the actual listener exception as the `cause`), which provides access to the container's `group.id` property.
892
892
893
893
Because the listener container has it's own mechanism for committing offsets, it prefers the Kafka `ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG` to be `false`.
@@ -914,7 +914,7 @@ See its JavaDocs and xref:kafka/receiving-messages/message-listener-container.ad
914
914
When using `AckMode.MANUAL` (or `MANUAL_IMMEDIATE`) you can now cause a redelivery by calling `nack` on the `Acknowledgment`.
915
915
See xref:kafka/receiving-messages/message-listener-container.adoc#committing-offsets[Committing Offsets] for more information.
916
916
917
-
Listener performance can now be monitored using Micrometer `Timer`s.
917
+
Listener performance can now be monitored using Micrometer ``Timer``s.
918
918
See xref:kafka/micrometer.adoc[Monitoring] for more information.
919
919
920
920
The containers now publish additional consumer lifecycle events relating to startup.
@@ -942,7 +942,7 @@ See xref:kafka/annotation-error-handling.adoc#dead-letters[Publishing Dead-lette
942
942
[[cb-2-2-and-2-3-topicbuilder]]
943
943
=== TopicBuilder
944
944
945
-
A new class `TopicBuilder` is provided for more convenient creation of `NewTopic` `@Bean`s for automatic topic provisioning.
945
+
A new class `TopicBuilder` is provided for more convenient creation of `NewTopic` ``@Bean``s for automatic topic provisioning.
946
946
See <<configuring-topics>> for more information.
947
947
948
948
[[cb-2-2-and-2-3-kafka-streams-changes]]
@@ -971,7 +971,7 @@ Also a `JacksonMimeTypeModule` has been introduced for serialization of `org.spr
971
971
See its JavaDocs and xref:kafka/serdes.adoc[Serialization, Deserialization, and Message Conversion] for more information.
972
972
973
973
A `ByteArrayJsonMessageConverter` has been provided as well as a new super class for all Json converters, `JsonMessageConverter`.
974
-
Also, a `StringOrBytesSerializer` is now available; it can serialize `byte[]`, `Bytes` and `String` values in `ProducerRecord`s.
974
+
Also, a `StringOrBytesSerializer` is now available; it can serialize `byte[]`, `Bytes` and `String` values in ``ProducerRecord``s.
975
975
See xref:kafka/serdes.adoc#messaging-message-conversion[Spring Messaging Message Conversion] for more information.
976
976
977
977
The `JsonSerializer`, `JsonDeserializer` and `JsonSerde` now have fluent APIs to make programmatic configuration simpler.
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/micrometer.adoc
+1-1
Original file line number
Diff line number
Diff line change
@@ -117,5 +117,5 @@ To do so, add a custom `KafkaListenerObservationConvention` and/or `KafkaTemplat
117
117
The `record` property in both observation contexts contains the `ConsumerRecord` or `ProducerRecord` respectively.
118
118
119
119
The sender and receiver contexts `remoteServiceName` properties are set to the Kafka `clusterId` property; this is retrieved by a `KafkaAdmin`.
120
-
If, for some reason - perhaps lack of admin permissions, you cannot retrieve the cluster id, starting with version 3.1, you can set a manual `clusterId` on the `KafkaAdmin` and inject it into `KafkaTemplate`s and listener containers.
120
+
If, for some reason - perhaps lack of admin permissions, you cannot retrieve the cluster id, starting with version 3.1, you can set a manual `clusterId` on the `KafkaAdmin` and inject it into ``KafkaTemplate``s and listener containers.
121
121
When it is `null` (default), the admin will invoke the `describeCluster` admin operation to retrieve it from the broker.
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/message-listener-container.adoc
+1-1
Original file line number
Diff line number
Diff line change
@@ -82,7 +82,7 @@ return container;
82
82
83
83
Note that when creating a `DefaultKafkaConsumerFactory`, using the constructor that just takes in the properties as above means that key and value `Deserializer` classes are picked up from configuration.
84
84
Alternatively, `Deserializer` instances may be passed to the `DefaultKafkaConsumerFactory` constructor for key and/or value, in which case all Consumers share the same instances.
85
-
Another option is to provide `Supplier<Deserializer>`s (starting with version 2.3) that will be used to obtain separate `Deserializer` instances for each `Consumer`:
85
+
Another option is to provide ``Supplier<Deserializer>``s (starting with version 2.3) that will be used to obtain separate `Deserializer` instances for each `Consumer`:
Copy file name to clipboardExpand all lines: spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/sending-messages.adoc
+2-2
Original file line number
Diff line number
Diff line change
@@ -286,7 +286,7 @@ Calling `reset()` or `destroy()` will not clean up these producers.
286
286
287
287
Also see xref:kafka/transactions.adoc#tx-template-mixed[`KafkaTemplate` Transactional and non-Transactional Publishing].
288
288
289
-
When creating a `DefaultKafkaProducerFactory`, key and/or value `Serializer` classes can be picked up from configuration by calling the constructor that only takes in a Map of properties (see example in xref:kafka/sending-messages.adoc#kafka-template[Using `KafkaTemplate`]), or `Serializer` instances may be passed to the `DefaultKafkaProducerFactory` constructor (in which case all `Producer`s share the same instances).
289
+
When creating a `DefaultKafkaProducerFactory`, key and/or value `Serializer` classes can be picked up from configuration by calling the constructor that only takes in a Map of properties (see example in xref:kafka/sending-messages.adoc#kafka-template[Using `KafkaTemplate`]), or `Serializer` instances may be passed to the `DefaultKafkaProducerFactory` constructor (in which case all ``Producer``s share the same instances).
290
290
Alternatively you can provide `Supplier<Serializer>`+++s+++ (starting with version 2.3) that will be used to obtain separate `Serializer` instances for each `Producer`:
0 commit comments