Releases: spring-projects/spring-kafka
Releases · spring-projects/spring-kafka
v3.1.6
⭐ New Features
- Add tracing headers to be mapped to string #3288
🔨 Dependency Upgrades
- Bump org.springframework.data:spring-data-bom from 2023.1.6 to 2023.1.7 #3316
- Bump io.projectreactor:reactor-bom from 2023.0.6 to 2023.0.7 #3315
- Bump org.springframework:spring-framework-bom from 6.1.8 to 6.1.9 #3314
- Bump io.micrometer:micrometer-tracing-bom from 1.2.6 to 1.2.7 #3313
- Bump io.micrometer:micrometer-bom from 1.12.6 to 1.12.7 #3312
- Bump org.springframework:spring-framework-bom from 6.1.7 to 6.1.8 #3279
v3.2.0
⭐ New Features
- Implement CommonErrorHandler.handleOne() in CommonDelegatingErrorHandler #3227
🐞 Bug Fixes
- Documentation for configuring custom
ConsumerFactory
andProducerFactory
beans when using Spring Boot is incorrect #3242 - Switch
EmbeddedKafaka#kraft
default tofalse
#3238 - Creation of
kafkaJaasInitializer
bean fails in a read-only filesystem due to creation of temporary file #3217 - KafkaTemplate currentSpan tagging issue #3210
📔 Documentation
- Adding more whats-new for kakfa-client 3.7.0 #3253
- Minor docs cleanup #3245
- Update Boot versions in docs #3233
- Embedded Kafka throws NoSuchFileException #3225
- Fix enforceRebalance #3215
- Fix ackDiscarded. #3212
🔨 Dependency Upgrades
- Bump org.springframework.data:spring-data-bom from 2024.0.0-SNAPSHOT to 2024.0.0 #3273
- Bump org.springframework.retry:spring-retry from 2.0.5 to 2.0.6 #3272
- Bump io.projectreactor:reactor-bom from 2023.0.5 to 2023.0.6 #3270
- Bump org.springframework:spring-framework-bom from 6.1.6 to 6.1.7 #3269
- Bump com.fasterxml.jackson:jackson-bom from 2.17.0 to 2.17.1 #3249
- Bump kotlinVersion from 1.9.23 to 1.9.24 #3248
- Bump org.jetbrains.kotlinx:kotlinx-coroutines-reactor from 1.8.0 to 1.8.1 #3247
❤️ Contributors
Thank you to all the contributors who worked on this release:
v3.1.5
⭐ New Features
- Implement CommonErrorHandler.handleOne() in CommonDelegatingErrorHandler #3230
🐞 Bug Fixes
- Documentation for configuring custom
ConsumerFactory
andProducerFactory
beans when using Spring Boot is incorrect #3244 - Creation of
kafkaJaasInitializer
bean fails in a read-only filesystem due to creation of temporary file #3219 - KafkaTemplate currentSpan tagging issue #3213
🔨 Dependency Upgrades
- Bump org.springframework:spring-framework-bom from 6.1.6 to 6.1.7 #3262
- Bump org.springframework.data:spring-data-bom from 2023.1.5 to 2023.1.6 #3261
- Bump io.projectreactor:reactor-bom from 2023.0.5 to 2023.0.6 #3260
- Bump org.springframework.retry:spring-retry from 2.0.5 to 2.0.6 #3259
- Bump io.micrometer:micrometer-tracing-bom from 1.2.5 to 1.2.6 #3258
- Bump io.micrometer:micrometer-bom from 1.12.5 to 1.12.6 #3257
- Bump kotlinVersion from 1.9.23 to 1.9.24 #3252
v3.0.17
v3.2.0-RC1
⭐ New Features
@PartitionOffset
supprt TopicPartitionOffset.SeekPosition #3178- Add an option to leave consumer group when closing Streams #3168
- Add
checkstyle
rule onempty-line-separater
#3162 - Remove org.apache.kafka native runtime hints #3147
- Adding new
KafkaListenerEndpointRegistry.getListenerContainersMatchingId(predicate: Predicate<String>)
#3135 - Allows to initialize/inject the Topology object without starting the Kafka streams. #3020
- More and proper tags for observation spans #2609
🐞 Bug Fixes
- Duplicate record consumption due to offset decrease in last offset commit #3186
- Setting the Kafka Streams property
default.dsl.store
has no effect #3176 - BatchInterceptor is not working properly with retries #3166
- MDCs are missing in logs produced by DefaultErrorHandler. #3151
- In kafka events, the traceId and spanId are not written in the logs #3146
📔 Documentation
- fix typo in JsonDeSerializer.TYPE_MAPPINGS #3144
- Spring Kafka not working properly with Java 21 Virtual Threads, listeners are tied to a platform thread forever #3074
🔨 Dependency Upgrades
- Bump org.springframework:spring-framework-bom from 6.1.5 to 6.1.6 #3194
- Bump io.projectreactor:reactor-bom from 2023.0.4 to 2023.0.5 #3193
- Bump log4jVersion from 2.23.0 to 2.23.1 #3157
❤️ Contributors
Thank you to all the contributors who worked on this release:
@JooHyukKim, @juwit, @sobychacko, and @system205
v3.1.4
🐞 Bug Fixes
- Duplicate record consumption due to offset decrease in last offset commit #3190
- Setting the Kafka Streams property
default.dsl.store
has no effect #3181 - BatchInterceptor is not working properly with retries #3170
- MDCs are missing in logs produced by DefaultErrorHandler. #3154
- In kafka events, the traceId and spanId are not written in the logs #3149
🔨 Dependency Upgrades
- Bump org.springframework.data:spring-data-bom from 2023.1.4 to 2023.1.5 #3201
- Bump org.springframework:spring-framework-bom from 6.1.5 to 6.1.6 #3200
- Bump io.micrometer:micrometer-bom from 1.12.4 to 1.12.5 #3199
- Bump io.micrometer:micrometer-tracing-bom from 1.2.4 to 1.2.5 #3198
- Bump io.projectreactor:reactor-bom from 2023.0.4 to 2023.0.5 #3197
v3.0.16
🐞 Bug Fixes
- Duplicate record consumption due to offset decrease in last offset commit #3191
- Setting the Kafka Streams property
default.dsl.store
has no effect #3182 - BatchInterceptor is not working properly with retries #3171
- MDCs are missing in logs produced by DefaultErrorHandler. #3153
- In kafka events, the traceId and spanId are not written in the logs #3150
🔨 Dependency Upgrades
v3.2.0-M2
⭐ 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
inKafkaStreamsInteractiveQueryService
#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 ofAfterRollbackProcessor
#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
v3.1.3
⭐ New Features
- fix bug at KafkaMessageListenerContainerTests.testInvokeRecordInterceptorAllSkipped() #3094
- Align RecordInterceptor and BatchInterceptor lifecycle. #3092
- ConcurrentMessageListenerContainer#isInExpectedState consistency problem #3068
- Fix TestOOMError#testOOMCMLC throw ConcurrentModificationException #3061
🐞 Bug Fixes
- Failing to handle deserialization exceptions in batch listener #3118
KafkaMessageListenerContainer
doesn't properly clear threadState ofAfterRollbackProcessor
#3102- Listener exceptions not saved to the observation #3085
- CommonDelegatingErrorHandler does not check delegates compatibility correctly #3062
- DefaultErrorHandler is not able to seek in case of an exception during the commit #3060
📔 Documentation
- Remove retry-topic-lcf.adoc introduce useLegacyFactoryConfigurer #3087
🔨 Dependency Upgrades
- Bump org.springframework.data:spring-data-bom from 2023.1.3 to 2023.1.4 #3139
- Bump org.springframework:spring-framework-bom from 6.1.4 to 6.1.5 #3134
- Bump io.micrometer:micrometer-bom from 1.12.3 to 1.12.4 #3132
- Bump kotlinVersion from 1.9.22 to 1.9.23 #3131
- Bump io.micrometer:micrometer-tracing-bom from 1.2.3 to 1.2.4 #3127
- Bump io.projectreactor:reactor-bom from 2023.0.3 to 2023.0.4 #3125
- Bump org.apache.zookeeper:zookeeper from 3.8.3 to 3.8.4 #3124
v3.0.15
⭐ New Features
- Provide a way to support Consumer#enforceRebalance #3075
🐞 Bug Fixes
- Failing to handle deserialization exceptions in batch listener #3119
KafkaMessageListenerContainer
doesn't properly clear threadState ofAfterRollbackProcessor
#3103- Listener exceptions not saved to the observation #3086