spring-projects/spring-kafka v3.2.0-M2

on GitHub

⭐ New Features

• Upgrade Apache Kafka client version to 3.7.0 #3116
• @RetryableTopic support KL annotated on class part 2 #3112
• @RetryableTopic support @KafkaListener annotated on class part 1 #3107
• Correct class naming convention for 'hat' in serializer/deserializer Doc #3106
• polish retryable topic. #3104
• fix bug at KafkaMessageListenerContainerTests.testInvokeRecordInterceptorAllSkipped() #3091
• Polish KafkaMessageListenerContainer #3090
• Fix race condition at TransactionalContainerTests.testBatchListenerRecoverAfterRollbackProcessorCrash #3081
• Polish KafkaMessageListenerContainer #3079
• Compute New Seek Position From Current Offset #3078
• GH-2775: Deprecate ContainerProperties properties transactionManager #3066
• Polish KafkaTemplate #3065
• ConcurrentMessageListenerContainer#isInExpectedState consistency problem #3063
• Fix TestOOMError#testOOMCMLC throw ConcurrentModificationException #3059
• ReactiveKafkaConsumerTemplate missing receiveBatch method #3057
• Change @RetryableTopic properties SameIntervalTopicReuseStrategy behavior to SINGLE_TOPIC #3052
• Add properties to ContainerProperties.toString #3046
• polish adoc for kafka chapter #3045
• Cleanup ConcurrentMessageListenerContainerMockTests #3044
• Provide API methods of accessing HostInfo in KafkaStreamsInteractiveQueryService #3034
• Non-blocking retry using KafkaListener on class level #3012
• Use application name as default clientId #3001

🐞 Bug Fixes

• Failing to handle deserialization exceptions in batch listener #3114
• Unsafe access to Kafka consumer in seek operation #3108
• KafkaMessageListenerContainer doesn't properly clear threadState of AfterRollbackProcessor #3076
• CommonDelegatingErrorHandler does not check delegates compatibility correctly #3050
• Listener exceptions not saved to the observation #3049
• Enhanced monitoring when KMLC is batch listener #3047
• fix bug about method ConsumerSeekAware.seekRelative #3043
• DefaultErrorHandler is not able to seek in case of an exception during the commit #3019
• Calling DefaultKafkaHeaderMapper constructor with the same ObjectMapper instance may result memory leak #2611

📔 Documentation

• Remove retry-topic-lcf.adoc introduce useLegacyFactoryConfigurer #3084
• Non-Blocking Retries cannot combine with container transactions. #3072

🔨 Dependency Upgrades

• Bump org.springframework:spring-framework-bom from 6.1.4 to 6.1.5 #3130
• Bump io.projectreactor:reactor-bom from 2023.0.3 to 2023.0.4 #3129
• Bump org.apache.zookeeper:zookeeper from 3.8.3 to 3.8.4 #3111
• Bump kotlinVersion from 1.9.22 to 1.9.23 #3110
• Bump com.github.spotbugs from 6.0.7 to 6.0.8 #3096

❤️ Contributors

Thank you to all the contributors who worked on this release:

@Wzy19930507, @qeeqez, @selllami, and @sobychacko