spring-kafka
Provides Familiar Spring Abstractions for Apache Kafka
APACHE-2.0 License
Bot releases are hidden (Show)
Published by garyrussell over 2 years ago
Change log:
c93304ae Upgrade Versions; Prepare for Release
9675989d Update Gradle Enterprise plugin
4bce5267 GH-2306: Improve DeserEx Message For Improper Ex.
168b9d27 Add Converter Factories to Method Factory
273416c8 GH-2304: Fix SendTo on Interface Etc.
1d60eda5 GH-2297: Add KLERegistry.alwaysStartAfterRefresh
e88711f7 GH-1482: Make Topic Config Update Optional
ec2608b9 GH-1482: Support Admin.incrementalAlterConfigs
a1f112c5 Add Acknowledgment.nack() variants accepting Duration
a9a19a73 GH-2295: No Resolvers with ConsumerRecordMetadata
23a103e0 Log Uncommitted After Rebalance
1e82ac9c GH-2292: Doc - Fix Container Factory Generics
5101b17f GH-2286: Doc Fixes
07e4bc80 Precise unit for sleep duration and wake time
388b23f8 GH-2148: Use ObjectProvider to Locate MeterRegistry
ba309fb6 GH-2274: Option to Not Configure (De)serializers
Published by garyrussell over 2 years ago
Change log:
59a1c82a Upgrade Versions; Prepare for Milestone Release
db54e24b GH-2274: Option to Not Configure (De)serializers
db0f958d Upgrade kafka-clients to 3.2.0; other upgrades
02d3b724 GH-2269: Improve DLPR Extensibility
f94620ae GH-2252: Keep offset metadata in case of batch reprocessing (#2253)
731af322 GH-2128: More Doc Polishing
df4e0aad GH-2260: Reduce Header Constant Verbosity
a957b399 GH-2249: Batch Listener LISTENER_INFO Headers
03b00092 GH-2225: Fix New Package Tangle
01a14019 GH-2128: Document Nack Sleep Time Limitations
e1160fa7 GH-2172: Expose Retry Topic Chain at Runtime (#2245)
f200c037 GH-2226: Remove Obsolete Test
b2beec31 GH-2226: Add RetryTopicConfigurationSupport
44e3f524 Change Some Tests to Parameterized
ab871abb GH-2240: Bug fix for KafkaTemplate.receive(..) Fixes GH-2240 (https://github.com/spring-projects/spring-kafka/issues/2240)
920089bf Fix Sonar Issue
21a5ada2 Make artifactoryPublish dependsOn build
4915d6fe Switch to Micrometer 1.10.0-SNAPSHOT
8ccdbd7a Fix TopicPartitionOffset Hash Code (NPE)
80b1770e GH-2220: Fix TopicPartitionOffset for Retry Topics (#2223)
01d36722 Revert "Temporarily Restore Deprecations Affecting SIK"
edd7c6d1 Fix Javadocs For Removed Error Handlers
777d7f39 Fix Links to Boot Documentation
cdf05a6e Update Gradle Enterprise plugin to 3.9
af56eca3 GH-2195: DefaultErrorHandler Improvements
c6355724 Fix What's New
40d1ec20 Fix What's New Title
feb35635 GH-2222: Re-Pause Paused Partitions After Rebal.
e1e46c62 Adapt to latest Micrometer Binders changes
e0fee7e0 GH-2212: Log listener exception in retry topic flow (#2213)
02784654 GH-2218 add ability to pass AdminClient
10905dc5 GH-2214: Fix Manual Nack with Zero Sleep
f53d41b3 GH-2208: Add Paragraph to Doc
34c56199 GH-2208: Fix Manual Nack with Mutating Interceptor
6022835e GH-2197: Fix Container State After Fatal Stop
1c98623d Upgrade Jackson Version
50498f98 GH-2170: Support Custom OffsetAndMetadata
bf36c64e KafkaStreamsDefConfig: Remove unused configuredBy
e6bd735d GH-2198: Move to Micrometer Snapshots
408623c8 GH-2059: expose adminTimeout property in EmbeddedKafka annotation (#2194)
31b78c43 fixed spacing in dead letter publishing failed message.
448871ac GH-2184 KafkaBackOffException logged as ERROR
d65a9f05 DLPR - Generate Header Values Lazily
Published by garyrussell over 2 years ago
Change log:
7f5395da Upgrade Versions; Prepare for Release
041ce862 GH-2269: Improve DLPR Extensibility
6e92b7f9 GH-2252: Keep offset metadata in case of batch reprocessing (#2253)
9a36d9b1 GH-2128: More Doc Polishing
1708bf41 GH-2249: Batch Listener LISTENER_INFO Headers
fc544cd5 GH-2128: Document Nack Sleep Time Limitations
60c8f6c4 Add JUnit5 params Module to Build
f90c8e1a GH-2240: Bug fix for KafkaTemplate.receive(..)
63e56a78 Fix Sonar Issue
34e1950c Make artifactoryPublish dependsOn build
fe74dbf5 Revert "Make artifactoryPublish depend on build"
Published by garyrussell over 2 years ago
Change log:
9e9501d7 Upgrade Versions; Prepare for Release
56b77562 GH-2268: Fix DLPR Record Logging
a1c20924 GH-2269: Improve DLPR Extensibility
Published by garyrussell over 2 years ago
Change log:
fa076905 Make artifactoryPublish depend on build
f823b3a5 Upgrade versions; prepared for release
2f45a820 Fix TopicPartitionOffset Hash Code (NPE)
cbca786f GH-2220: Fix Test After Back Port
00725743 GH-2220: Fix TopicPartitionOffset for Retry Topics (#2223)
c8635975 GH-2222: Fix Race in Test
3903d1a7 Fix Links to Boot Documentation
7103483a GH-2222: Re-Pause Paused Partitions After Rebal.
41542717 GH-2212: Log listener exception in retry topic flow (#2213)
e7db6d47 GH-2218 add ability to pass AdminClient
26de6d29 GH-2214: Fix Manual Nack with Zero Sleep
dc81e7c4 GH-2208: Add Paragraph to Doc
340ac792 Fix test compatibility with the RecordInterceptor
a67a2307 GH-2208: Fix Manual Nack with Mutating Interceptor
fea221f6 GH-2197: Fix Container State After Fatal Stop
94721d5c Upgrade Jackson Version
5246daa3 GH-2170: Support Custom OffsetAndMetadata
56504915 GH-2059: adminTimeout property on @EmbeddedKafka
da0b820d GH-2184 KafkaBackOffException logged as ERROR
5df194ef DLPR - Generate Header Values Lazily
93efeb4f GH-2182 - Capitalize title in docs
Published by garyrussell over 2 years ago
Change log:
7813e9d2 Upgrade Spring, Reactor versions
7a58a2ba Upgrade versions; prepare for release
a781be7f Fix TopicPartitionOffset Hash Code (NPE)
39276ead GH-2220: Fix TopicPartitionOffset for Retry Topics (#2223)
f8310720 GH-2222: Fix Race in Test
051ceb54 Fix Links to Boot Documentation
cd43976b GH-2222: Re-Pause Paused Partitions After Rebal.
c3d97791 GH-2212: Log listener exception in retry topic flow (#2213)
a89895bd GH-2208: Add Paragraph to Doc
7a191294 Use correct ConsumerRecord ctor in the test
9510d441 Add missed import for Optional
e1c59c52 Fix test compatibility with the RecordInterceptor
549e2430 GH-2208: Fix Manual Nack with Mutating Interceptor
afc689ab Upgrade Jackson Version
Published by garyrussell over 2 years ago
Change log:
478cf6d2 GH-2182 - Capitalize title in docs
6c05000f Upgrade Spring Data to M3
ee3fc601 Exclude Micrometer from spring-data
379d158f Fix Gradle Sha
c96f5115 Upgrade versions; prepare for release
3bc00a9a GH-2178: Fix CSA.onPartitionsAssigned (Manual)
e4d96411 GH-2179: Exit RetryingBatchErrorHandler on Stop
bf3dc8c4 Fix typo
ceaf437d GH-2164: Remove More Dead Code
03a2124d GH-2164: Remove EOSMode.V1
a8f98bdb GH-1886: Fix Javadocs
ec69ddc1 GH-1886 More RetryTemplate Related Deprecations
be7d128d Fix typo
d983f0b2 GH-2153: Remove ConsumerProp.onlyLogRecordMetadata
ca9d1008 More KafkaHeaderMapper Javadocs
aba4ee2e Fix KafkaHeaderMapper Javadocs
f83fc4b1 GH-2155: DeadLetterPublishingRecoverer Improvement
6fc037ed Fix NPE
77444ab7 Fix Sonar Issues
6e4c819e GH-2162: Fix Record Interceptor Javadocs
bee97d9c GH-2154: Fix Tombstones with Delegating Seriali...
f0ad7b0c GH-2153: Switch to ConsumerRecord Formatter
bbf26bc1 Temporarily Restore Deprecations Affecting SIK
dc47e72a GH-2148: Fix MeterRegistry Detection
a1a5d48f GH-2128 Do Not Sleep Consumer Thread for Nack
1fa80aad Fix JavaDocs typo in the KafkaUtils
891664b6 GH-2132: Producer Record Log Formatting
17b738ea GH-2134: Doc and Javadoc Polishihg
66b91de0 Fix Compiler Warnings
86c9aa1d GH-2134: Add filter to @KafkaListener
a7dbb783 GH-2072: Remove Invalid Deprecation Suppressions
c2362f14 Upgrade to Micrometer 2.0.0-SNAPSHOT
43cb7812 Docs - Fix ToC
52d45dc5 Add Nullable to API methods
c6b2f9c8 Remove Unnecessary Suppress Warning
9741d281 GH-615: Docs - Migrating Legacy Error Handlers
9f48d007 Fix Doc Typo
2e23b1b6 Add getter for StreamsUncaughtExceptionHandler (#2144)
009abbb2 Fix Sonar Issues
675a68c2 GH-2140: Improve generics for DelegatingByTypeSer
24d7cad1 GH-2139: Clarify ExponentialBackOff maxDelay default
ae80c5d0 More sample-01 README Fixes
cc912425 Fix sample-01 README
01549a6e GH-2116: Add blocking retries to RT (#2124)
dad2061c GH-2135: Fix NPE in JsonDeserializer
864a3185 GH-2135: Fix array support for mappings
38ed222a GH-2049: Spring Managed Producer Interceptors (#2112)
c27de92b ExceptionClassifier Reverse Option
b198c5b7 Revert Micrometer Upgrade to M2
Published by garyrussell over 2 years ago
Change log:
243e68c1 GH-2178: Fix CSA.onPartitionsAssigned (Manual)
b27a0d6a Upgrade versions; prepare for release
a78a3cd2 GH-2179: Exit RetryingBatchErrorHandler on Stop
e9310c05 Fix typo
e0a27118 GH-1886: Fix Javadocs
ea7cc330 GH-1886 More RetryTemplate Related Deprecations
59f25508 Fix KafkaHeaderMapper Javadocs
f3f3eac9 GH-2155: DeadLetterPublishingRecoverer Improvement
a1ca1944 Fix Sonar Issues
f96edc00 GH-2162: Fix Record Interceptor Javadocs
ea503860 GH-2154: Fix Tombstones with Delegating Seriali...
8ec7ed0b GH-2132: Deprecate ListenerUtils.recordToString
60fd3e82 GH-2148: Fix MeterRegistry Detection
be4b1bf9 GH-2128 Do Not Sleep Consumer Thread for Nack
220262d1 Fix JavaDocs typo in the KafkaUtils
f6e4a7d0 GH-2132: Producer Record Log Formatting
15bef9db GH-2134: Doc and Javadoc Polishihg
96231161 Fix Compiler Warnings
279b7539 GH-2134: Add filter to @KafkaListener
0ac422e3 Add Nullable to API methods
9d3d0340 Docs - Fix ToC
1e5915d9 Fix Deprecation Warning in Test
6b603165 GH-615: Docs - Migrating Legacy Error Handlers
1bc6f397 Fix Sonar Issues
30206191 Add getter for StreamsUncaughtExceptionHandler (#2144)
b09619b5 Fix Sonar Issues
9fdb6c31 GH-2139: Clarify ExponentialBackOff maxDelay default
a7621a10 GH-2116: Add blocking retries to RT (#2124)
841a6b78 GH-2135: Fix NPE in JsonDeserializer
796624e9 ExceptionClassifier Reverse Option
Published by garyrussell over 2 years ago
Change log:
eedcac99 GH-2179: Exit RetryingBatchErrorHandler on Stop
43ed676b GH-2178: Fix CSA.onPartitionsAssigned (Manual)
51ff88a8 Fix typo
8cf808c9 Fix KafkaHeaderMapper Javadocs
9a9f1905 GH-2162: Fix Record Interceptor Javadocs
e46d2986 GH-2154: Fix Tombstones with Delegating Seriali...
bd3d43f5 Partial Revert "GH-2132: Producer Record Log Fo..."
fccd680d Fix JavaDocs typo in the KafkaUtils
297f52da GH-2132: Producer Record Log Formatting
8291609e GH-2139: Clarify ExponentialBackOff maxDelay default
682ff7ab GH-2135: Fix NPE in JsonDeserializer
Published by garyrussell over 2 years ago
Change log:
f338d563 Add what's new and docs for RT's new features
3c9e00fa GH-2117: Make ListenerContainerFactoryConfigurer ctor public
6f63a57a GH-2118: Make DLPR skip same topic fatal ex optional
d052f158 GH-2113: Add ex classification to DDTopicResolver
f51ddd43 Fix Micrometer Moved Package Names
4e2f9fd2 Upgrade versions; prepare for milestone release
469edfaf GH-2069: Same factory for retryable and normal endpoints (#2108)
19c6b234 Change Spring repositories to official
b3709a2b GH-2109: Increase EKB Zookeeper Timeouts
7abea2f9 Issue Template Polishing
1346cacc Doc Polishing
bf30d5ca Revise Issue Template, Etc.
ea9601e4 Non-Responsive Consumer Doc Polishing
b8670e8f Fix Event Consumption ToC
7c2178ac GH-2089: Remove 2.x Deprecations
b30e4b3a GH-2099: Deprecate RetryingBatchErrorHandler
38d34135 Deprecate Accessors for Legacy Error Handlers
ad08a14d add nullable annotation to FailedRecordTracker.setBackOffFunction
babfa51f Fix Missing Topics Fatal Javadoc
edf3825b Docs: fixed "Handling Exceptions" section levels
8169f4de GH-2076: Fix Async Commit Retries
fe0f58e4 JsonSerde Improvement
97d60b7c GH-2085: DelegatingByTypeSerializer Improvements
a1d57389 Bump up Gradle plugin dependencies
0fc1548d GH-2070: Producer Factory Improvements
0d430b95 GH-2082: Fix RecordInterceptor
7ddbf128 Upgrade Kafka Clients to 3.1.0
a63ad4c2 Improve CommitAsync Retries Test
Published by garyrussell over 2 years ago
Change log:
810a4c80 Add what's new and docs for RT's new features
427b0249 GH-2117: Make ListenerContainerFactoryConfigurer ctor public
8580d709 GH-2118: Make DLPR skip same topic fatal ex optional
92ccb559 GH-2113: Add ex classification to DDTopicResolver
e2750e1d Upgrade versions; prepare for release
a1102599 GH-2069: Same factory for retryable and normal endpoints (#2108)
2cb2adf9 Change Spring repositories to official
fefebd18 GH-2109: Increase EKB Zookeeper Timeouts
3325e36d Doc Polishing
c20b0fbb Non-Responsive Consumer Doc Polishing
1c045a26 Fix Event Consumption ToC
22737f51 GH-2089: Add Deprecations for 3.0 Removal
9300f7ca GH-2099: Deprecate RetryingBatchErrorHandler
36a52972 Deprecate Accessors for Legacy Error Handlers
5728ed7d add nullable annotation to FailedRecordTracker.setBackOffFunction
550b7185 Fix Missing Topics Fatal Javadoc
9722b842 GH-2076: Fix Async Commit Retries
4637d2f3 JsonSerde Improvement
10e73b55 GH-2085: DelegatingByTypeSerializer Improvements
b669c12d GH-2070: Producer Factory Improvements
917134d2 GH-2082: Fix RecordInterceptor
dd64db8b 2.8.x kafka-clients 3.1.0 Compatibility
Published by garyrussell over 2 years ago
Change log:
5a31b54f Upgrade versions; prepare for release
fe4a002a Change Spring repositories to official
03bc4e22 GH-2109: Increase EKB Zookeeper Timeouts
4753512e Non-Responsive Consumer Doc Polishing
93d60897 Fix Event Consumption ToC
7007c6b6 add nullable annotation to FailedRecordTracker.setBackOffFunction
676a5ad6 Fix Missing Topics Fatal Javadoc
45a6b06b GH-2076: Fix Async Commit Retries
dfce233f GH-2082: Fix RecordInterceptor
Published by garyrussell almost 3 years ago
Change log:
cc2ae4c8 Fix Micrometer Test
ed3ca330 Upgrade Micrometer Version
3e2d273c Fix Spring Data Version
6b08c1bc Upgrade Versions; Prepare for Milestone Release
44c2115b Main to 3.0; SF 6.0; JDK 17
Published by garyrussell almost 3 years ago
Change log:
9f75c9dd Upgrade Versions; Prepare for Release
95fc922a Log KafkaBackoffException at DEBUG Level
65a7fd27 GH-2061: Remove Unused Variable
64891b3c GH-2061: Remove Unused Variable
b72a37fd GH-2061: EKB Seek to End Option for Embedded Topics
6a5fdc68 Upgrade Gradle Kotlin Plugin
248cd704 GH-2055: Containers Must Implement DisposableBean
5e4e6b4a Upgrade Log4j to 2.17.1 (Tests Only)
Published by garyrussell almost 3 years ago
Change log:
1c9a0137 Upgrade Versions; Prepare for Release
3574c5c9 GH-2055: Containers Must Implement DisposableBean
7f510780 Upgrade Log4j to 2.17.1 (Tests Only)
8f3b573c Upgrade Log4j to 2.17.0 (Tests Only)
9e6df044 Upgrade Log4j to 2.16.0 (Tests Only)
c62e2e32 Upgrade Log4j to 2.15.0 (Tests Only)
f775ffb3 Fix ClassCastException in ChainedKTM
Published by garyrussell almost 3 years ago
Change log:
69817cb9 Upgrade Spring Framework Version
129b2bf1 GH-2055: Containers Must Implement DisposableBean
4cc23d4b Upgrade Log4j to 2.17.1 (Tests Only)
af9115dd Upgrade Log4j to 2.17.0 (Tests Only)
3d73e370 Upgrade Log4j to 2.16.0 (Tests Only)
4dc252da Upgrade Log4j to 2.15.0 (Tests Only)
97210dcc Fix ClassCastException in ChainedKTM
Published by garyrussell almost 3 years ago
Change log:
66b5c39e Upgrade Spring Framework, Reactor Versions
0b376c99 GH-2055: Containers Must Implement DisposableBean
82349c13 Fix Typo in JUnit Jupiter Version
2c488d2a Upgrade Log4j to 2.17.1 (Tests Only)
76a4e0b4 Upgrade Log4j to 2.17.0 (Tests Only)
db119731 Upgrade Log4j to 2.16.0 (Tests Only)
35f18278 Fix ClassCastException in ChainedKTM
a2484a77 Remove non-compatible TX test
38ed17de GH-2001: Propagate Exception from TX Sync Commit
38390e89 Restore generic args for anonymous classes
c4787fc8 GH-1983: Support copy of producer factory
Published by garyrussell almost 3 years ago
Change log:
cf16e3a0 Upgrade versions; prepare for release
02213b45 GH-2050: Configure ErrHandlDeser if no delegate
146c4913 Upgrade Log4j to 2.17.0 (Tests Only)
1fd454a5 Fix New Sonar Issue
ec6c6b3b Upgrade Log4j to 2.16.0 (Tests Only)
bac7166a GH-2046: Add Property to Always Check for Deser Ex
03a5e42c GH-2038: Fix DelegatingByTopicSerialization Config
4f44ad4e Upgrade to Gradle 7.3.1
2fb53600 Improve the override deps docs (#2042)
ebf70133 GH-2041: Fix Embedded Broker Error When Downgrading
a2eb4f76 Upgrade Log4j to 2.15.0 (Tests Only)
910030eb Polish Samples
ba9fb41a GH-2036: Deserialization Errors and Batches
fbb38aae Fix streams.adoc for streamsBuilderFB sample
60e21e06 Cast transactionManager to interface KafkaAwareTransactionManager instead of KafkaTransactionManager.
f26a0007 Simple log typo fix
c061fce5 GH-2018: Docs - Downgrading to Apache Kafka 2.8.1
319c114c Docs: fix some broken links
8e7c72f8 Bump up Gradle enterprise plugin to 3.7.2
f2362865 Fix typo in the whats-new.adoc
Published by garyrussell almost 3 years ago
Change log:
f759800f Upgrade versions; prepare for release
ab3945df Fix New Sonar Issues
a3ee6108 GH-2000: Doc RetryTopic Publish with Deser. Errors
505bd841 GH-2001: Propagate Exception from TX Sync Commit
82cb03ec GH-1902: AuthenticationException Fatal By Default
15e771a6 GH-2003: Fix RetryableTopic Delivery Attempts Hdr
df4a5b11 GH-1994: Fix Typos in Doc
bcdd523b GH-1991: Exclude slf4j impl and log4j via Zookeeper
0ebad523 Upgrade jfrog-cli for Central Action
387d435e GH-1994: Option to Strip Exception Headers
42fef6e9 GH-1982: Boot 2.6 Compatibility (Retryable Topics)
d2bf7467 Fix JavaDoc
1b84562d Add nullable annotation on ContainerProperties.transactionManager getter/setter
4eb4d9d1 GH-1983: Fix New Sonar Issues
05357604 Fix Checkstyle violation
00bf6aee GH-1983: No ProducerFactory copy in KafkaTemplate
d4b88b02 GH-1983: Support copy of producer factory
4e2a2379 GH-1981: Optionally Don't Start the DLT Container
9675fead Fix Deprecation Warnings
Published by garyrussell almost 3 years ago
Change log:
6cfa2263 Upgrade versions; prepare for release
3a87c5e6 GH-2000: Doc RetryTopic Publish with Deser. Errors
3da65a8c GH-2001: Propagate Exception from TX Sync Commit
1361a361 GH-2003: Fix RetryableTopic Delivery Attempts Hdr
6ed0b2e4 GH-1994: Fix Typos in Doc
9159ef96 GH-1994: Option to Strip Exception Headers
afc28837 Fix JavaDoc
c1f86687 Add nullable annotation on ContainerProperties.transactionManager getter/setter
c76e86f2 GH-1983: Support copy of producer factory
