spring-kafka

Change log:

482b5465 GH-1637: Fix TopicPartitionOffset.hashCode()
9a013e23 GH-1631: Remove unused topics from test
dca07ac3 GH-1631: fix missing @SendTo for cglib proxies
a2275942 GH-1633: Fix Race and Event
8cc23017 GH-1633: Do not stop parent container when fenced
9d61d73e Fix two small typos in the documentation
049ab3de GH-1621: Test Polishing
004c9198 GH-1621: Fix test for back-port
4892f27c GH-1621: Fix nack() with Tx Batch Listener

Change log:
7e21d653 Upgrade versions; prepare for release
7668f525 GH-1618: Remove Duplicate Parameter
5c1d2904 GH-1612: Fix Javadocs
c092202e JsonDeserializer - javadoc fix, minor changes
89b6ffc5 GH-1612: Option: Producer Fenced: Stop Container
078474ef GH-1615: Add maxAge to Producers
7ad38c09 GH-1613: Fix Race in Producer Factory
b9e28d75 GH-1610: Reset Retry State when Exception Changes
620c1a6f GH-1587: Fix NPE with Foreign TM and fixTxOffsets
9bb4334f GH-1587: Improve Javadocs for fixTxOffsets
212689cc DeadLetterPublishingRecoverer Docs
a6ee4b37 Upgrade Spring Data Version
7f04c446 Upgrade Dependency Versions
70af1ca1 Javadoc Polishing

Change log:

25fc8f9b GH-1618: Remove Duplicate Parameter
2240affb GH-1612: Fix Javadocs
49aedaa1 GH-1612: Option: Producer Fenced: Stop Container
f195b62b GH-1615: Add maxAge to Producers
e815ace6 GH-1613: Fix Race in Producer Factory
fb1977c1 GH-1587: Fix NPE with Foreign TM and fixTxOffsets
36abb92a GH-1604: Document Scala Incompatibility
ab6a1fd4 Remove extraneous file

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