spring-kafka

Change log:

d0207049 API Compatibility Back Ports
c558d2ba GH-1613: Fix Race in Producer Factory

Change log:

f5c3b79a Upgrade Reactor Version
5f6ec92b Fix Transitive Scala Library Version
c225c0d1 Fix Transitive Scala Library Version
d1a12282 Upgrade Versions; Prepare for Release
18f96158 GH-1597: Fix NPE
7caa7039 GH-1591: Apply BackOff in DARP with Batch Listener
86ac3e0e Expose @KafkaListener BPP method handler factory
31ea5c49 Fix doc typo

Change log:

eb17826a Upgrade Reactor Version
a456473e Upgrade Versions; Prepare for Release
bfccd6e8 GH-1591: Apply BackOff in DARP with Batch Listener

Change log:

22f488f3 Upgrade Reactor Version
08b1772b Upgrade Versions; Prepare for Release
a8d84979 GH-1591: Apply BackOff in DARP with Batch Listener

Change log:

88eaff6e Upgrade Dependency Versions; Prepare for Release
99ea1054 Doc Polishing
c8052211 GH-810: Resolve Sonar issue
25806645 GH-810: Add StreamsBuilderFB.setCleanupConfig()
43742ab6 GH-1597: Fix NPE
abe720b7 More Sonar Fixes
b275384e Sonar fixes
0c5867ea GH-1591: Apply BackOff in DARP with Batch Listener
0106acf6 Expose @KafkaListener BPP method handler factory
7acf1b9f @KafkaListener Javadoc Polishing
a1e6024a Upgrade to gradle 6.6.1
932b6098 Reformat test class
321b18f6 Add RecordMetadata to ProducerListener.onError
be0cc7c0 Add ListenerContainerNoLongerIdleEvent

Change log:

f1055649 Upgrade versions; prepare for release
bd911ad9 GH-1587: Don't Correct TX Offsets After Seek(s)
cee9bed8 GH-1587: Option to Correct Transactional Offsets
cb8183e3 Fix Default EOSMode in Properties Table
11d27a17 Fix typo
03e8c72d Json Converters Javadoc Polishing
7b0d196a Doc Polishing

Change log:

8e94fe4a Upgrade versions; prepare for release
5bc2ac6f GH-1587: Remove Java 11 Test Elements
ad246753 GH-1587: Don't Correct TX Offsets After Seek(s)
80aa8fde GH-1587: Option to Correct Transactional Offsets
a0e2b256 Doc Polishing
db001d4a GH-1582: Add GenericErrorHandler.setAckAfterHandle
fb975dd4 GH-1184: Add Exactly Once Test Case
cef32edd Remove duplicate test
3ba42d53 Fix Shutdown Race Causing Test Delays
18edc934 Fix Request/Reply with ConsumerRecord
72fddc19 GH-1569: Add Message Listener Advice Chain
24b9e964 GH-1565: ErrorHandlingDeserializer Extensions
fa983fd6 Fix idleBetweenPolls max value calculation
90c87c06 Add ConversionException in classifier to skip
a52f2fed GH-1563: Fix JUnit5 @EmbeddedKafka.partitions()

Change log:

62fc6f9f Upgrade versions; prepare for release
2010e94c Remove duplicate test
fbd9cfc4 Fix Shutdown Race Causing Test Delays
d60df680 Fix Request/Reply with ConsumerRecord
fd41e508 GH-1565: ErrorHandlingDeserializer Extensions
7303413f Fix idleBetweenPolls max value calculation
cca897b6 GH-1563: Fix JUnit5 @EmbeddedKafka.partitions()
045b1d09 GH-1550: Polish test
af0ad5b0 GH-1550: DefaultKafkaHeaderMapper - trust arrays
7a534019 Fix javadocs in back-port
3d1cd0ad ReplyingKTemplate Handle DeserializationException
ad7cad4f Fix Map Iteration
343df6d4 FIX: KafkaMessageListenerContainer#processTimestampSeeks offsetsForTimes method can return map with null values

Change log:

3202a9a6 Upgrade Micrometer version
5267b474 Upgrade versions; prepare for release
9a33485b Remove duplicate test
feac8d26 Fix Shutdown Race Causing Test Delays
2f048be4 Fix Request/Reply with ConsumerRecord
bc086ded GH-1565: ErrorHandlingDeserializer Extensions
d2bfca9c Fix idleBetweenPolls max value calculation
313852ab GH-1563: Fix JUnit5 @EmbeddedKafka.partitions()
ab63fec7 GH-1550: Polish test
84d3ade2 GH-1550: DefaultKafkaHeaderMapper - trust arrays
a19b29da Fix javadocs in back-port
8323d636 ReplyingKTemplate Handle DeserializationException
5b2fd49e Fix Map Iteration
f1f687b8 FIX: KafkaMessageListenerContainer#processTimestampSeeks offsetsForTimes method can return map with null values

Change log:

dc6d0d06 Transaction Doc Polishing
0e411db8 GH-1582: Add GenericErrorHandler.setAckAfterHandle
625bee23 GH-1184: Add Exactly Once Test Case

Change log:

8510afe9 Topic Provisioning - default partitions/replicas
6dae2f1f Remove duplicate test
5747b504 Fix Shutdown Race Causing Test Delays
003432a4 Fix Request/Reply with ConsumerRecord
9f56b5d0 Request/Reply Doc Polishing
4b91ea68 Transactions Doc Polishing
066a3c0e Json (de)serialization configuration improvements (#1573)
b2f8be61 Revert Spring Versions; prepare for RC
f6391bfd Fix Javadocs for JDK 11
c8cf57c4 Seek Improvements
8ae9a8da fix references to producerPerConsumerPartition
8bed6d51 Add Boot Compatibility Caveat
3aef04e5 GH-1569: Add Message Listener Advice Chain
61285ce9 GH-1565: ErrorHandlingDeserializer Extensions
689126e6 Fix idleBetweenPolls max value calculation
7da80926 Add ConversionException in classifier to skip
9776c42b GH-1563: Fix JUnit5 @EmbeddedKafka.partitions()

Change log:

1e7bd6ac Upgrade versions; prepare for milestone release
7fc9d6e2 Remove ProducerListener Deprecations
e563a934 Fix Race in Streams Micrometer Test
069a26a9 Upgrade Mockito, Spring versions
45756992 GH-1559: Fix Sonar Issues
c43a85f6 FailedRecordProcessors - selectable BackOff
bc65c9e2 Upgrade Scala Version
cb1fe225 GH-1547: Fix @since
5e32ad9a FailedRecordProcessor Polishing
35bdf28c Upgrade to Kafka 2.6.0 (GA)
000ce9a9 Fix doc typos
b6fbe582 GH-1552: Support more consumer properties override
820a125d GH-1554: Partition wildcard for initial offsets
069924c3 GH-1550: Polish test
72b9dd25 GH-1550: DefaultKafkaHeaderMapper - trust arrays
f947d9f6 Upgrade spring-retry version
7aa3d61d GH-1547: Reset BackOff State on Recovery Failure
ec984285 Fix Map Iteration
02870468 ReplyingKTemplate Handle DeserializationException
5f4dfccf FIX: KafkaMessageListenerContainer#processTimestampSeeks offsetsForTimes method can return map with null values
23fbd62b Remove deprectated ErrorHandlingDeserializer2
e3ef1924 GH-1451: Exactly Once Semantics Mode BETA Default
6b0f74c5 Make the example compile
ae15fb0f More javadoc polishing
de9b64ba Javadoc polishing
4500f168 More doc polishing
758fbe61 More doc polishing
42a1b234 Doc Polishing
e02e4592 JavaDoc Polishing
d48875c4 GH-1538: Resolve Sonar Issue
0b0f22ed Add docs.
81f99d94 GH-1538: Embedded broker get results for addTopics
d6a17b5e Shut down context in ABSwitchClusterTests
2018f268 Add Consumer test case for ABSwitchCluster
41856c2d Fix doc typo
4de5b666 Remove Micrometer Test Diagnostics
ff347bf6 Fix Race in Micrometer Metrics Test
d974513d GH-1518: Remove Spring Integration Chapter
f1af7efd Add more ABSwitchCluster documentation
e6933479 Upgrade to Kafka 2.6.0 RC0
f887d5c3 Wording changes
1a443f7f Doc polishing for the previous commit
6dd162c3 DeadLetterPublishingRecoverer Improvements
7004a264 GH-1531: fixed NPE in MicrometerHolder during app shutdown (#1532)
d76781d2 ConsumerRecord Logging Improvement
d5f579ea KafkaTemplate Javadoc re Thread-safety
59afa756 Fix documentation (#1530)
775428b9 More docs.
61247021 Fix indent.
dad0e5b0 GH-1527: Add Support for Transaction Properties

Change log:

87cae7f8 Upgrade versions; prepare for release
3178db2c Fix Race in Streams Micrometer Test
9cade314 Uncomment version override appendix
e76fc5c0 Upgrade to kafka 2.5.1
e58f683d GH-1547: Fix @since
885574ef Fix doc typos
4587d7e5 GH-1554: Partition wildcard for initial offsets
dee102f3 GH-1550: Polish test
b215ca40 GH-1550: DefaultKafkaHeaderMapper - trust arrays
06daa07a Fix Race in Micrometer Metrics Test
8182df8f GH-1547: Reset BackOff State on Recovery Failure
aca09bad ReplyingKTemplate Handle DeserializationException
cd9bad47 Fix Map Iteration
898d008a Fix Seeking to Timestamp when no offset returned
2885ef3a Javadoc polishing
56138dba More doc polishing
2b78025e More doc polishing
c4b5e852 Doc Polishing

Change log:

80c2706f Upgrade versions; prepare for release
e653cc44 GH-1538: Embedded broker get results for addTopics
fa7917df Fix doc typo
0267f1a2 SIK Docs for Send Timeout Change
35bb0224 Add more ABSwitchCluster documentation
f887d5c3 Wording changes
1a443f7f Doc polishing for the previous commit
6dd162c3 DeadLetterPublishingRecoverer Improvements
7004a264 GH-1531: fixed NPE in MicrometerHolder during app shutdown (#1532)
d76781d2 ConsumerRecord Logging Improvement
d5f579ea KafkaTemplate Javadoc re Thread-safety
59afa756 Fix documentation (#1530)
775428b9 More docs.
61247021 Fix indent.
dad0e5b0 GH-1527: Add Support for Transaction Properties

Change log:

ee6f0677 Upgrade versions; prepare for release
b42c135c Add BeanNameAware to Producer/Consumer Factories
b241fec2 GH-1517: ConsumerSeekCallback Javadoc Polishing

Change log:

b1d02325 Upgrade versions; prepare for release
0ddff6db Add BeanNameAware to Producer/Consumer Factories
db306bfc GH-1517: ConsumerSeekCallback Javadoc Polishing

Change log:

8fbb7e33 GH-1520: Add Producer/Consumer Post Processors
28ff099c Upgrade Versions; Prepare for Release
58076068 GH-1522: Commit recovered record with MANUAL Acks
261e73ee GH-1519: Fix @SendTo on @KafkaHandler
ac7ab707 Fix Sonar Issue
ae0480fa GH-1517: More Javadoc Polishing
f2e8335b GH-1517: ConsumerSeekCallback Javadoc Polishing
41ea8304 GH-1501: StreamsBuilderFB.Listener Improvement
fe6255bf Polishing
b322a0da Fix Previous Commit
b6d5489b Fix Sonar issues
45fb5da4 Gradle 6.5; Support Building With Java 14
7974331b GH-1508: Fix DefaultARProcessor for EOSMode.BETA
76f88199 GH-1509 Support nested BatchListenerFailedException in RecoveringBatchErrorHandler
2186774d JsonDeserializer Type Resolution Improvements
7ba7e8cb Fix Sonar Issue
8e72af6c Fixed typos in readme
e788c705 GH-1501: Add Micrometer Support for KafkaStreams

Change log:

94324e8d Update versions; prepare for release
af83f604 GH-1499: Option to suppress ConsumerRecord logging
b226d6c9 Add kafka-streams to version override appendix
dfe9f487 Corrects two typos
452ec6c7 GH-1496: Fix RetriableException
0cb722e5 GH-1496: Handle RetriableCommitFailedException
96efd3fa GH-1494: Fix NPE in DeadLetterPublishingRecoverer
0281b776 Fix "since" version

Change log:

6e27a0a5 Update versions; prepare for release
ce506ea3 GH-1499: Option to suppress ConsumerRecord logging
959f0f5e Add kafka-streams to version override appendix
c476ac6a Corrects two typos
3fe295e6 GH-1496: Handle RetriableCommitFailedException
5aff841c GH-1494: Fix NPE in DeadLetterPublishingRecoverer
96b4369b Support keys in Delegating(De)Serializer
9a6398dd Make container.getGenericErrorHandler() public
1fefc1ea Make container.getAfterRollbackProcessor() public
4a583b5f GH-1487: @KafkaListener Meta-Annotation on Class
38fdafde GH-1485: Option to suppress single client.id suffx
663b28fa Fix fatal early return from onPartitionsAssigned
7d28888a Fix cherry-pick
63943c8c Don't commit on assignment with existing commit
4f56a3ae Doc Polishing
b23506e3 Fix import in the test
9a33f51f Fix commit on assignment for earliest setting
24073803 Manage log.dir in the EmbeddedKafkaBroker

Change log:

f18303c7 Update versions; prepare for release
803725d7 GH-1499: Option to suppress ConsumerRecord logging
7f793f4d Corrects two typos
4da47f57 GH-1496: Handle RetriableCommitFailedException
27f2f65d GH-1494: Fix NPE in DeadLetterPublishingRecoverer
a3c8fc0a Support keys in Delegating(De)Serializer
84162f08 Make container.getGenericErrorHandler() public
d2872bc4 Make container.getAfterRollbackProcessor() public
0a4d272f GH-1487: @KafkaListener Meta-Annotation on Class
cc139866 GH-1485: Option to suppress single client.id suffx
b5e28e72 Fix fatal early return from onPartitionsAssigned
c20b8d2f Fix cherry-pick
edaf3549 Don't commit on assignment with existing commit
2a6d3ede Doc Polishing
2e337c92 Fix commit on assignment for earliest setting
8bef5eff Manage log.dir in the EmbeddedKafkaBroker