Skip to content

Latest commit

 

History

History
92 lines (59 loc) · 3.5 KB

whats-new.adoc

File metadata and controls

92 lines (59 loc) · 3.5 KB

What’s New in 2.8 Since 2.7

This section covers the changes made from version 2.7 to version 2.8. For changes in earlier version, see [history].

Kafka Client Version

This version requires the 3.1.0 kafka-clients

Important
 When using transactions, the minimum broker version is 2.5.

See [exactly-once] and KIP-447 for more information.

Package Changes

Classes and interfaces related to type mapping have been moved from …​support.converter to …​support.mapping.

  • AbstractJavaTypeMapper

  • ClassMapper

  • DefaultJackson2JavaTypeMapper

  • Jackson2JavaTypeMapper

Out of Order Manual Commits

The listener container can now be configured to accept manual offset commits out of order (usually asynchronously). The container will defer the commit until the missing offset is acknowledged. See [ooo-commits] for more information.

@KafkaListener Changes

It is now possible to specify whether the listener method is a batch listener on the method itself. This allows the same container factory to be used for both record and batch listeners.

See [batch-listeners] for more information.

Batch listeners can now handle conversion exceptions.

See [batch-listener-conv-errors] for more information.

RecordFilterStrategy, when used with batch listeners, can now filter the entire batch in one call. See the note at the end of [batch-listeners] for more information.

KafkaTemplate Changes

You can now receive a single record, given the topic, partition and offset. See [kafka-template-receive] for more information.

CommonErrorHandler Added

The legacy GenericErrorHandler and its sub-interface hierarchies for record an batch listeners have been replaced by a new single interface CommonErrorHandler with implementations corresponding to most legacy implementations of GenericErrorHandler. See [error-handlers] for more information.

Listener Container Changes

The interceptBeforeTx container property is now true by default.

The authorizationExceptionRetryInterval property has been renamed to authExceptionRetryInterval and now applies to AuthenticationException s in addition to AuthorizationException s previously. Both exceptions are considered fatal and the container will stop by default, unless this property is set.

See [kafka-container] and [container-props] for more information.

Serializer/Deserializer Changes

The DelegatingByTopicSerializer and DelegatingByTopicDeserializer are now provided. See [delegating-serialization] for more information.

DeadLetterPublishingRecover Changes

The property stripPreviousExceptionHeaders is now true by default.

See [dlpr-headers] for more information.

Retryable Topics Changes

Now you can use the same factory for retryable and non-retryable topics. See [retry-topic-lcf] for more information.

There’s now a manageable global list of fatal exceptions that will make the failed record go straight to the DLT. Refer to [retry-topic-ex-classifier] to see how to manage it.

The KafkaBackOffException thrown when using the retryable topics feature is now logged at DEBUG level. See [change-kboe-logging-level] if you need to change the logging level back to WARN or set it to any other level.