spring-kafka
Provides Familiar Spring Abstractions for Apache Kafka
APACHE-2.0 License
Stars
2.1K
Committers
215
Bot releases are hidden (Show)
spring-kafka
- v3.1.0
Published by garyrussell 11 months ago
β New Features
- remove unnecessary property setting statement in EmbeddedKafkaKraftBroker #2893
- GH-2654: Incorrect retry topic suffix #2876
- The TRUSTED_PACKAGES field in the DefaultJackson2JavaTypeMapper has also been improved to have an ImmutableList type. #2875
- No early bean initialization from
EmbeddedKafkaContextCustomizer#2870 - GH-2862: Add Option to Log Recovery to DLPR #2869
- Support Validator in ErrorHandlingDeserializer #2861
- GH-2731: fix count and time ack mode #2858
- If cluster id is null and observation is enabled, KafkaTemplate tries to retrieve it on each produce #2853
- Provide a way to define a ContainerCustomizer per KafkaListener #2825
π Bug Fixes
- Fix TX Check in RoutingKafkaTemplate #2899
- Fix Issues in DefaultKafkaProducerFactory#updateConfigs() #2897
- Under-documented "Manually Assigning All Partitions" #2891
- add a missing left quote in AbstractKafkaListenerEndpoint#getEndpointDescription() #2882
- fix CONSUMER_RECORDS_CLASS_NAME constant error in KafkaAvroBeanRegistrationAotProcessor.java #2881
- ProducerInterceptor in KafkaTempalte unvaild #2874
- Admin is boot up by turning on observability #2859
π Documentation
- Improve Documentation about Acknowledgment.nack() #2906
- Improve Documentation: State on OOO-Commits page that AsyncAcks cannot be combined with nack() #2905
- remove 'dead links' in javadocs #2896
- Update testing.adoc > "
@EmbeddedKafkaAnnotation with JUnit5" section #2894 - fix some typos #2885
- update reference documentation gradle task in README.md #2880
- cosmetic doc improvements part 4 #2879
- cosmetic doc improvements part 3 #2877
- some cosmetic improvements of the reference - part 2 #2873
- Streams Doc Polishing #2871
- Reference Doc Improvements #2867
π¨ Dependency Upgrades
π¨ Tasks
- Eliminate the Use of StringBuffer #2909
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@Alchemik, @NathanQingyangXu, @Wzy19930507, @ch4570, @pat-goins, and @powibol
External Links
spring-kafka
- v3.0.13
Published by garyrussell 11 months ago
β New Features
- If cluster id is null and observation is enabled, KafkaTemplate tries to retrieve it on each produce #2856
π Bug Fixes
- Under-documented "Manually Assigning All Partitions" #2901
- The result of
ProducerInterceptor.onSend()is out of use #2884 - Fix CONSUMER_RECORDS_CLASS_NAME constant error in KafkaAvroBeanRegistrationAotProcessor #2883
π¨ Dependency Upgrades
π¨ Tasks
- Add kafka-server-common Transitive Test Dependency #2849
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@Wzy19930507
External Links
β New Features
π Bug Fixes
- KafkaAdmin NPE With Typo in Config Name #2832
- CommonDelegatingErrorHandler: Missing updateClassifier() in addDelegate() #2826
- KafkaTemplate is reporting 2 errors to observation on immediate errors (one in callback and one in catched exception from the same callback) #2817
π Documentation
- Fix Invalid exposeGroupId in Docs #2828
π¨ Dependency Upgrades
- Upgrade to Apache Kafka 3.6.0 #2827
π¨ Tasks
External Links
spring-kafka
- v3.0.12
Published by garyrussell about 1 year ago
π Bug Fixes
- Remove Arrays.toString() from JsonDeserializer #2839
- KafkaAdmin NPE With Typo in Config Name #2834
- CommonDelegatingErrorHandler: Missing updateClassifier() in addDelegate() #2830
- KafkaTemplate is reporting 2 errors to observation #2824
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Micrometer, Reactor Versions #2846
π¨ Tasks
- Deprecate DestinationTopicPropertiesFactory CTORs #2793
- Remove outdated comments in ListenerContainerFactoryConfigurer #2776
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@WhiteDG
External Links
spring-kafka
- v2.9.13
Published by garyrussell about 1 year ago
π Bug Fixes
- Remove Arrays.toString() from JsonDeserializer #2840
- KafkaAdmin NPE With Typo in Config Name #2835
- CommonDelegatingErrorHandler: Missing updateClassifier() in addDelegate() #2831
π Documentation
- Document Using Kafka 3.6.0 With This Version #2844
π¨ Dependency Upgrades
- Upgrade Micrometer, Reactor, Spring Data Versions #2845
π¨ Tasks
- Remove outdated comments in ListenerContainerFactoryConfigurer #2788
External Links
spring-kafka
- v3.1.0-M1
Published by garyrussell about 1 year ago
π Documentation
π¨ Tasks
- Initial docs-deploy #2802
- Remove deprecated interfaces, classes, and methods #2797
- Output of
asciidoctorPdfcan be pulled from cache when run on machines with different checkout directories #2794 - Move main to 3.1; Upgrade Dependency Versions #2790
- Examine synchronized Blocks #2730
- Remove ThreadLocal Usage #2729
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@erichaagdev, @esperar, and @rwinch
External Links
spring-kafka
- v3.0.10
Published by garyrussell about 1 year ago
β New Features
- Private Header Type for DeserializationExceptions #2770
- Add KafkaMessageHeaderAccessor #2767
- Consider to expose a
spring.kafka.bootstrap-serversSystem property withEmbeddedKafkaBroker#2750 - Partial positive acknowledge support for BatchAcknowledgingMessageListener #2066
π Bug Fixes
- AdminClient doesn't use configured properties while starting a container listener #2762
- Sync Gradle .module Files to Maven #2753
π¨ Dependency Upgrades
- Upgrade Jackson, Micrometer, Reactor, Spring Data Versions #2778
- Upgrade Gradle, SonarQub, Jacoco, NoHttp Versions #2758
π¨ Tasks
- Add ConfigFile Runtime Hint (for JAAS) #2772
- Implement Lifecycle in DefaultKafkaProducerFactory #2760
- Clean Up Gradle Enterprise Config #2757
- Refactor DeserializationException Detection Code #2756
External Links
spring-kafka
- v2.9.11
Published by garyrussell about 1 year ago
spring-kafka
- v3.0.9
Published by garyrussell over 1 year ago
β New Features
- FallbackBatchErrorHandler - Consider Seeking and Exiting Retries When Container is Paused #2742
- Make KafkaAdmin Easier to Subclass and Add a Filter Mechanism #2720
- GH-2709: Preserve existing JAAS configuration #2713
- Add DLPR Creator Function to DeadLetterPublishingRecovererFactory #2711
π Bug Fixes
- Possible dead lock between DefaultKafkaProducerFactory.expire and DefaultKafkaProducerFactory.removeProducer #2744
- GH-2738: Pausing container results in WakeupException without retrying failed listener invocation #2739
- NullPointerException in KafkaRecordReceiverContext #2736
- Fix Race Condition in DelegatingInvocableHandler #2723
- Behavior Change When Interceptor Throws an Exception #2722
π Documentation
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Micrometer, Reactor Versions #2746
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@WhiteDG, @antonio-tomac, and @edanidzerda
External Links
spring-kafka
- v2.9.10
Published by garyrussell over 1 year ago
β New Features
- Make KafkaAdmin Easier to Subclass and Add a Filter Mechanism #2726
- GH-2709: Preserve existing JAAS configuration #2718
- Auto Config Non-Blocking Retries with asyncAcks #2707
π Bug Fixes
- Possible dead lock between DefaultKafkaProducerFactory.expire and DefaultKafkaProducerFactory.removeProducer #2748
- Pausing container results in WakeupException without retrying failed listener invocation #2740
- Behavior Change When Interceptor Throws an Exception #2728
- Fix Race Condition in DelegatingInvocableHandler #2725
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Micrometer, Reactor Versions #2745
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@antonio-tomac and @edanidzerda
External Links
spring-kafka
- v3.0.8
Published by garyrussell over 1 year ago
β New Features
- MMConverter Support Custom Partition Selection #2703
- Auto Config Non-Blocking Retries with asyncAcks #2702
- Consider providing custom KafkaSender to ReactiveKafkaProducerTemplate #2190
π Bug Fixes
π Documentation
- Non-Blocking Retries don't work with BatchListener #2699
- Fixed Typo #2698
- docs: fix Javadoc of CommonErrorHandler::remainingRecords #2691
- docs: fix name of overriden method #2684
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Retry, Micrometer, Reactor Versions #2710
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@rajadilipkolli, @sculeb, and @tbcs
External Links
spring-kafka
- v3.0.7
Published by garyrussell over 1 year ago
β New Features
π Bug Fixes
π Documentation
- Howewever -> However #2670
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Reactor, Micrometer Versions #2682
π¨ Tasks
- Expose user exception thrown during rebalance #2667
- Remove duplicate native hint registration. #2659
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@MatejNedic and @michaldo
External Links
spring-kafka
- v3.0.6
Published by garyrussell over 1 year ago
β New Features
- GH-2638: Support Dynamic Tags via Observation #2650
- Support Dynamic Micrometer Tags Based on Consumer/Producer Record #2638
π Bug Fixes
- Races in KafkaListenerAnnotationBeanPostProcessor on scope=prototype bean instantiation #2642
- "resetStateOnExceptionChange" has no effect, because the cause of "ListenerExecutionFailedException" is always a "TimestampedException" #2641
π Documentation
- Missing upgrade section in the documentation for KafkaHeaders changes #2640
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Micrometer, Reactor, JUnit Versions #2657
External Links
spring-kafka
- v2.9.8
Published by garyrussell over 1 year ago
β New Features
- Support Dynamic Micrometer Tags Based on Consumer/Producer Record #2649
π Bug Fixes
- "resetStateOnExceptionChange" has no effect, because the cause of "ListenerExecutionFailedException" is always a "TimestampedException" #2646
- Races in KafkaListenerAnnotationBeanPostProcessor on scope=prototype bean instantiation #2644
π¨ Dependency Upgrades
- Upgrade Spring Framework, Data, Reactor, Micrometer Versions #2656
External Links
spring-kafka
- v3.0.5
Published by garyrussell over 1 year ago
π Bug Fixes
- Deadlock on lifecycleMonitor #2627
- Allow the Spring Cloud Stream Binder to Inject a KafkaAdmin for Observability #2626
- Reclassify Exception in FallbackBatchErrorHandler When Exception Changes #2620
- Spring Kafka Listener uses stale oauthbearer token, fails to connect after initial token expired. #2612
π¨ Dependency Upgrades
- Upgrade Micrometer, Reactor, Spring Versions #2634
External Links
spring-kafka
- v2.9.7
Published by garyrussell over 1 year ago
π Bug Fixes
- Deadlock on lifecycleMonitor #2630
- Reclassify Exception in FallbackBatchErrorHandler When Exception Changes #2623
- Spring Kafka Listener uses stale oauthbearer token, fails to connect after initial token expired. #2614
- Synchronized kafka transaction is not committed nor rolled back when code from custom "afterCommit" throws exception #2606
- Spring Messaging batch payload incompatible with Kotlin #2603
- KafkaMessageListenerContainer pauses for a long time after error handling #2598
π¨ Dependency Upgrades
- Upgrade Spring Framework to 5.3.26 #2633
External Links
spring-kafka
- v3.0.4
Published by garyrussell over 1 year ago
β New Features
- spring-kafka-test does not work with spring native graalvm #2582
- GH-2496: Reuse retry topic for maxInterval delay #2497
- Feature Request: Provide
DestinationTopic.Properties#isRetryTopic()method #2377
π Bug Fixes
- Synchronized kafka transaction is not commited nor rolled back when code from custom "afterCommit" throws exception #2604
- Spring Messaging batch payload incompatible with Kotlin #2600
- KafkaMessageListenerContainer pauses for a long time after error handling #2596
π Documentation
- Updated README.md #2594
π¨ Dependency Upgrades
- Upgrade Spring Framework, Reactor Versions #2607
β€οΈ Contributors
Thank you to all the contributors who worked on this release:
@esivakumar18 and @jgslima
External Links
Package Rankings
Top 2.68% on Repo1.maven.org
Top 8.17% on Proxy.golang.org
Badges
Extracted from project README
