spring-kafka

Change log:

f2541279 Update versions; prepare for release
3294f6c0 GH-1499: Option to suppress ConsumerRecord logging
423deb01 Corrects two typos
def2e879 Make container.getGenericErrorHandler() public
d76a4fa2 Make container.getAfterRollbackProcessor() public
30300946 GH-1487: @KafkaListener Meta-Annotation on Class
29381744 GH-1485: Option to suppress single client.id suffx
0cbf5690 Doc Polishing
a21fdebd Manage log.dir in the EmbeddedKafkaBroker

Change log:

b404785d DLPR: Restore/deprecate KafkaTemplate CTORs
a9b9d44c Support keys in Delegating(De)Serializer
ae03a536 Delegating(De)Serializer Improvements
0f43e343 Update samples to Boot 2.3.0
cca92049 Make container.getGenericErrorHandler() public
302a3bc7 Make container.getAfterRollbackProcessor() public
36992f81 SIK Doc Polishing
c0dfe83c GH-1487: @KafkaListener Meta-Annotation on Class
c97c34cf GH-1485: Fix new Sonar issue
61dea04d GH-1485: Fix javadoc

Change log (since Release Candidate 1):

25fa074c Fix checkstyle for new Hamcrest import
8626b7c2 Upgrade Versions for Release
0c942d4e GH-1485: Option to suppress single client.id
05e56ad1 GH-1483: Trust target class sub-packages
be3c6420 GH-1479: ConsumerRecordMetadata
c831259b Add missed rootProject for Checkstyle location
0fe7424b Fix Checkstyle to rely on the absolute path
ed14bcfb Fix Sonar issue
6a61cad6 Add getAssignmentsByClientId() to containers
b51a778c Fix fatal early return from onPartitionsAssigned
18104098 GH-1475: Add KafkaSendCallback
b1f33aaf Don't commit on assignment with existing commit
4a57a8dc Doc Polishing
2aef947c Fix commit on assignment for earliest setting
6d2bd6f1 Manage log.dir in the EmbeddedKafkaBroker
2db5263d Doc Fix
9a961aac Fix docsZip task for new doc location

Change log:

2d7eeab2 Merge pull request #1470 from garyrussell/ARBPDecorate
f9535fc1 Upgrade Micrometer, Spring Data versions
d308f909 Remove confusing logging statement
433e73a4 Upgrade Asciidoctor
6fc8ce44 Resolve new Sonar issues
8347b957 Support switching bootstrap servers at runtime
62c56925 Json Type Determination Using Methods
0692a8b6 Upgrade Reactor version
b68e82a4 Configure ParseStringDeserializer with Properties
b977e341 Upgrade to Spring Data Neumann
7ec2ee79 Close thread bound producers after reset
ecdd0582 Prevent EmbeddedKafkaBroker exiting the JVM
c5586f28 Easier management of Producer/Consumer Listeners
0d943323 Fix unchecked in test
529eca2a Upgrade spring-doc-resources
1369d2e8 Fix Sonar issues
d16089c4 More diagnostics for meters
730ddceb GH-1461: Configurable log level for EH Exceptions
de39d85c Fix diagnostics
2f9929b1 Add diagnostics for flaky test
fd50c843 Fix Appendix
f25bccd6 Polish docs for previous commit
4c313955 Producer/Consumer Factory Listeners and Micrometer
37dc6d60 Fix KafkaStreamBrancher doc typos
4100d4cc Polishing To/From String Ser/Des
2f3c6820 FEATURE: ToStringSerializer
d107d320 Fix new package tangle
139d80b9 Add kafka-clients version to What's New?
63a69706 Change Default Error Handlers
8c654bfb Fix commits on partition revocation
67645fca GH-1430: Polishing; Copy Remaining Properties
2a712fa4 GH-1445: Handle RebalanceInProgressException
ea0067f8 GH-1443: Doc polishing
2114d108 GH-1443: Add support for new EOS BETA
60842e5b Comment out appendix
13b08524 Upgrade to kafka-clients 2.5.0
780f7021 Fix assigned partitions with cooperative rebalance
ddaf3058 GH-1446: Resolve Sonar Issue
30f727d0 GH-1446: Support Static Group Membership
3e512f72 Fix streams docs
bc9fd8d2 GH-1441: Fix Sonar Issues
d69c82fc GH-1441: Remove unused code
a37fd8ab GH-1441: Close producer after fatal send error
ab643986 GH-1437: Check for immediate failure on send
df4c6a24 GH-1435: Add RecoveringBatchErrorHandler
71fe46a7 KafkaTemplate#send(V data) doesn't exists
915261dd Add RoutingKafkaTemplate
97c478af Various doc fixes
7c07bb0c GH-1430: Remove unused field
36a5147e GH-1430: Support Producer Property Overrides
3ef9340f Change default test consumer config a.o.r=earliest
682d68f6 Update samples to use current boot autoconfigure
19485c3d Restore PDF generation
6e1093b8 Upgrade to docResources 0.2.0
d042d158 Sonar possible null dereference
498af3cc Polish transaction synchronization test
16d449ea GH-1370: Container props: Polish, Defaults, Docs
0b53c4e6 Upgrade to Gradle 6.3
4e9777de GH-1424: Abort delivery on ProducerFencedException
ce8a3a09 Upgrade dependencies
2da4ad17 Don't populate a null RECEIVED_MESSAGE_KEY
5123b702 SIK Docs - flushExpression
d1e6a2c4 Add test for non-fatal auth. exceptions
02b4d74d Upgrade to Gradle 6.2.2
142afe3e Resolve Sonar Issue
d0129c13 Container Refactoring
3dc1fe44 Fix manual acks with transactions
c3d331e1 GH-1416: Add test for sub-batch abort
9bb7ec4a Upgrade kafka-clients to 2.4.1
eaa3d424 Upgrade Jackson version
8090a09f GH-1414: ConcurrentMLC Fix ConcurrentModification
07abecf0 Remove deprecations
f37ad667 Resolve Sonar Issue
2e97d382 GH-1366: Add Micrometer timers to KafkaTemplate
1412c2ad DeadLetterPublishingRecoverer improvements
e6c906cc Fix broken JavaDocs
6ec365bf GH-1382: RetryingBatchErrorHandler
554da611 Fix Gradle Deprecations
d5212f34 GH-1399: Resolve Sonar Issues
be12053d GH-1399: Reply Message<?> Headers
bc560717 GH-1402: Container retries delivery attempt header
062faa63 Upgrade asciidoc and other versions
582b8997 Update whats-new.adoc to 2.5
c5198b34 Master to 2.5; Upgrade Gradle to 6.1.1
c0dbc6ee Remove unnecessary directives (conventions plugin)
7ccf9d93 GH-1397: Channel doc polishing
76dc266c Use Spring Gradle Enterprise Conventions Plugin
d5a8a4b0 GH-1400: Expose topology from StreamsBuilder

Change log:

b61e9d6e Upgrade dependency versions
9c029f74 Close thread bound producers after reset
03722143 Prevent EmbeddedKafkaBroker exiting the JVM
cae667ea Fix KafkaStreamBrancher doc typos
90c4c24b Fix commits on partition revocation
3c334f2d Update appendix to Kafka 2.4.1
2ca7e638 Fix assigned partitions with cooperative rebalance
9d03ef29 GH-1446: Support Static Group Membership
56e9669e GH-1441: Remove unused code
20c679ff GH-1441: Close producer after fatal send error
b40c2f70 GH-1437: Check for immediate failure on send

Change log:

bf22a8e0 Upgrade dependency versions
cef665e0 Close thread bound producers after reset
ffce143c Prevent EmbeddedKafkaBroker exiting the JVM
444f9289 Fix KafkaStreamBrancher doc typos
1d1a6a73 Fix test for previous back ported fix
2b6400de Fix commits on partition revocation
978868ec GH-1446: Support Static Group Membership
2bbcc8fc GH-1441: Remove unused code
ced67f1c GH-1441: Close producer after fatal send error
5441fb29 GH-1437: Check for immediate failure on send

Change log:

18e4240d Upgrade versions for release
c43c2dc9 Fix logger parameters order
9e561110 Prevent EmbeddedKafkaBroker exiting the JVM
650b448a Fix KafkaStreamBrancher doc typos
678d9d59 Fix test for previous back ported fix
5fa11d3c Fix commits on partition revocation
514f1f2c GH-1441: Close producer after fatal send error
a28fea84 GH-1437: Fix test logging
a408b837 GH-1437: Check for immediate failure on send
f520bb13 Fix manual acks with transactions
e00eb23c GH-1414: ConcurrentMLC Fix ConcurrentModification

Change log:

3d76427b Ugrade Gradle, Spring, Retry versions
c9443ee8 Prevent KafkaEmbedded exiting the JVM
7b492f5c GH-1441: Close producer after fatal send error
85996252 GH-1437: Check for immediate failure on send
3d04b599 Upgrade to Kafka 0.11.0.3
72f89a20 Fix manual acks with transactions
badcb8a2 GH-1414: ConcurrentMLC Fix ConcurrentModification
7f1268d4 Fix local variable name
902e9b36 GH-1283: Unique client.id for each producer
54d83f3c Polishing for previous commit
678a21b9 GH-1196: Use close(Duration) instead of close()

Change log:

d5299cf9 Upgrade Micrometer to 1.3.7
55524bd8 Upgrade dependencies
3fd8de3c GH-1424: Abort delivery on ProducerFencedException
021a29d0 Fix manual acks with transactions
3aad45ae Upgrade kafka-clients to 2.4.1

Change log:

7b5f385f Upgrade dependencies
a521a787 GH-1424: Abort delivery on ProducerFencedException
bb1c2790 Fix manual acks with transactions
fc949fe5 GH-1414: ConcurrentMLC Fix ConcurrentModification
f9a7e4f3 GH-1382: RetryingBatchErrorHandler
e148db5e GH-1400: Expose topology from StreamsBuilder

Change log:

05f23202 GH-1414: ConcurrentMLC Fix ConcurrentModification
f07925ef GH-1382: RetryingBatchErrorHandler
c0dbc6ee Remove unnecessary directives (conventions plugin)
7ccf9d93 GH-1397: Channel doc polishing
76dc266c Use Spring Gradle Enterprise Conventions Plugin
d5a8a4b0 GH-1400: Expose topology from StreamsBuilder

Change log:

33045d3e Upgrade versions ready for release
b28200a0 GH-1397: Docs for S-I-K Channels
f536406f GH-1388: DeadLetterPR: Don't start a Tx if allowed
13724058 GitHub instead ofJIRA in the contribution guidelines
3c62cc30 GH-1353: More javadoc polishing
74a51d40 GH-1353: Clarify AckMode with transactions
e3868dc5 GH-1385: JsonDeserializer - trim trusted packages
e292987e GH-1386: Fix StreamsBuilder customization
a7be6ac9 GH-1388: Support non-Tx with a Tx Template
31d08b40 Fix BatchToRecordAdapter

Change log:

ccb40088 Upgrade versions ready for release
5f2aa334 More @since fixes
21659ecf Fix @since in previous commit
abf2bfe0 Make ZK client timeouts configurable (#1380)
0001d20f GH-1369: Fix Fenced Consumer-based Producers
0d179e7b GH-1376: Fix ContainerCustomizer
959d344f GH-1354: Fix default BackOff with deprecated CTOR
e16b433b GH-1370: Opt. commit current offsets on assignment
705930c7 GH-1353: Fix sleep with BatchListener nack

Change log:

efc72330 Upgrade versions for release
2776d0ef Remove user test that was accidentally added
1e62d806 Doc typo fix
bc45df92 Fix inconsistent sync on fields in embedded broker
db1ca60d Make ZK client timeouts configurable (#1380)
f44193e4 GH-1369: Fix Fenced Consumer-based Producers
ba78721e GH-1376: Fix ContainerCustomizer
5e16cf00 Fix typo in reference adoc
a5597247 GH-1354: Fix default BackOff with deprecated CTOR
0db23217 Fix Sonar issue
e138fc09 GH-1370: Opt. commit current offsets on assignment
909af163 GH-1356: Add BatchToRecordAdapter
5716bf07 GH-1362: Add custom HandlerMethodArgumentResolvers
a3de5332 Document (de)serialization config properties
cd6c2aa8 GH-1353: Fix sleep with BatchListener nack
a26576e0 GH-681: Fix docs/deprecations for ProducerListener
2d1a1d22 GH-1358: KTU.getRecords() - add minRecords option

Change log:

98305d75 Upgrade Spring Data Moore
f4e9728a Fix Sonar issue
e03cac58 GH-1236: Add Streams infrastructure customizer
a080919e Fix Sonar issues
12c3b955 GH-1347: Fix @EmbeddedKafka with count > 1
26e67759 Update Doc copyright
716e7830 GH-1344: Enable updateCopyrights onlyIf grgit (#1345)
4f971568 Remove super()
24e1148f Fix Sonar issues
20414508 Fix return type
fc312912 kafka 2.4 dependencies

Change log:

668dcd55 Upgrade Spring Data Moore
3fad1932 GH-1347: Fix @EmbeddedKafka with count > 1
aec78073 GH-1340: Support returning a collection
2fd4ddb8 GH-990: DARP: Restore and deprecate old property
7a78cd1c Fix Javadoc typo
930e201b GH-1336: Introduce authExceptionRetryInterval
c1c25821 GH-1319: Agg. Replying Template improvement
8c8e56be Warn for non-String consumer property overrides
10127ec7 Javadoc Polishing
09e775f0 GH-1331: KMLC - treat auth. exceptions as fatal
ceb8a99d More docs for missingTopicsFatal: false by default
e12c2856 Fix docs for missingTopicsFatal: false by default
45902a57 KTU.producerProps doc polishing
39bf605b Fix wrong method name
e326722c Deprecate KTU.senderProps()
16a12fe3 Fix KafkaListenerEndpointRegistry.stop(Runnable)
9bfc8803 SendTo Doc Polishing
fde3b20a Fix Sonar issues
459b34cf Fix exception message in HeaderEnricher

Change log:

0381d5ce Upgrade Spring Data Lovelace
d70c2051 GH-1331: KMLC - treat auth. exceptions as fatal
1be02a36 Add gradle to test version override appendix
0e7a9c6a Fix BatchErrorHandler container argument

Change log:

a7e14733 GH-1340: Fix test
cad56460 GH-1340: Support returning a collection
a41da350 GH-990: DARP.commitRecovered - fix 'since'
a62621ee Fix Javadoc typo
627e5781 Add reset() to ProducerFactory

Change log:

d26dba28 GH-1336: Introduce authExceptionRetryInterval
5f5ac21b Fix unused import
b66c6126 Fix new Sonar smells
bdf99674 Fix appendix
6fb3e5ad Fix a couple typos in Docs
dd914d2c GH-1319: Agg. Replying Template improvement
b2d6518a Upgrade to 2.4 clients; bump to 2.4.0.B-S

Change log:

67b7019f Upgrade Spring Data Commons
69e04475 Upgrade Spring, Micrometer versions
9992a6ec GH-1321: Add intercept before Tx option
42f26806 GH-1323: Fix missing javadoc
e03de25e GH-1323: s-k-test remove hard AssertJ dependency
0a95ec9b GH-1323: Fix import
e5b9cf56 Quick Start Doc Polishing (version)
cda70d47 Add gradle to test version override appendix
ad7b856f Restore addGitMetadata; only publish failures
38d326f3 Upgrade to Gradle 6.0
29403eb2 missingTopicsFatal false by default
c91d491d GH-1309: Fix NPE when no syncCommitTimeout set
e4e59f93 Revert "Remove verbose mock logging"
ace9d8b3 Add ContainerCustomizer
ae79b698 Remove verbose mock logging
426b1ae1 Fix checkstyle for previous commit
76b5c996 Fix logger name in FailedRecordProcessor
98a6354d Upgrade AssertJ, Hamcrest
534780d7 ConsumerSeekAware Improvement
eccfb4c8 Don't delay batch offset commits
1cd3ebfa Fix Sonar issues
b5dfbe9e GH-1299: Add AssertJ keyValue Condition
2643f5f2 GH-1293: Fix KafkaTestUtils.getSingleRecord()
23766997 GH-1291: Fix ApplicationEvent documentation
ab5f57b0 GH-1301: Make DefKafkaHMapper backward compatible