spring-kafka

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

Change log:

fad8c586 GH-1294: Fix mapping empty String header values

Change log:

9cd361a4 Upgrade Reactor BOM
665685de Upgrade Spring dependencies
4c2f920d Upgrade to gradle 5.6.4
feb4fa00 GH-1289: STCEH - Fix IndexOutOfBoundsException
30dca499 GH-1287: Detect mis-configured deserialization
78a0f15a Upgrade samples to Boot 2.2.0.RELEASE
9eadf5bc Deprecate ZkClient in embedded broker
ec446d4d GH-1283: Unique client.id for each producer
ae0dec77 Upgrade Kafka clients to 2.3.1
2f734a76 GH-1278: Add filtered sub batch test
9a4e3f70 Remove implements TestRule from EmbeddedKafkaRule
48557516 GH-1278: Zombie Fencing with Batch Listener
5bd49b35 Suppress new Sonar smells
633f5663 GH-1273: Fix offset commit after recovery
e671eeaa GH-1274: Fix STCEH Deprecated CTOR
f77dcfbb Fix typo around NRCEvent properties

Change log:

1bb0962d Upgrade Spring dependencies
8d0bb399 GH-1287: Detect mis-configured deserialization
169f1189 GH-1283: Unique client.id for each producer
70c22586 Uptrade dependencies
59f91a73 Fix gradle updateCopyrights
d4fb7c4c GH-1271: Allow consumption of DLT published record
a1d4c965 Fix typo around NRCEvent properties

Final 2.1.x version

Change log:

f5bcaca1 Fix trailing whitespaces after previous merge
adb2f9a2 GH-1287: Detect mis-configured deserialization
36fdb2d3 GH-1283: Unique client.id for each producer
8c22b782 GH-1247: Polishing
309d28e2 GH-1247: Only wake consumer while polling
a91ffccc Polishing for previous commit
5f57f4b7 GH-1196: Use close(Duration) instead of close()

Change log:

2dd811f3 Add build scan to travis
6bf60082 Add opt-in integration with Gradle's build scans
b53c9348 Fix Sonar issues
457e63a5 GH-1260: Add exception classification to DARP
37a1b5be Remove unused field from FailedRecordTracker
fe7f8c1a Fix duplicated link in Docs
0ae9dcc8 GH-1259: Failed recovery with no retry
9abc873e GH-1259: Handle Failed Record Recovery
0feba30e Upgrade samples

Change log:

b05b04ce GH-1259: Handle Failed Record Recovery

Change log:

da9dc280 GH-1225: @KL - skip conversion when not needed
f86110e8 Fix Sonar issues
ba6adeaa Upgrade Spring and Micrometer versions
05ee48c1 @EmbeddedKafka javadoc polishing
fa723bc8 GH-1254: Fix javadoc
910233ec GH-1254: Configurable Embedded Zookeeper Port
2115cf62 Fix new Sonar smells
0d45644f GH-1252: Add more consumer lifecycle events
e90d9e6c Upgrade to Jackson 2.10
594d0052 DefaultKafkaHeaderMapper Improvement
ae711a8c GH-1247: Polishing
525c8a8d GH-1247: Only wake consumer while polling
a32b3b91 Fix new Sonar smells
5e002b55 Doc Polishing
2bc0775a Upgrade to Reactor Dysprosium-RELEASE
220a5aae GH-1244: ReplyingKTemplate reply timeout per send
8f4ca4ac Add Micrometer Timers to the KMLContainer
1224ddf7 Fix JavaDoc warning; downgrade ASCIIDoc plugin
9d6628b4 Upgrade dependencies (#1241)
0baa4471 Pull Up Consumer Properties
4f8fa13f GH-1234: Fix FailedRecordTracker
13ae3856 Fix Sonar issue
5c96d3fa GH-1231: KafkaTestUtils Enhancements

Change log:

d02c7333 Upgrade Spring Framework and Data versions
fabbb6f0 GH-1247: Polishing
7cfc482a GH-1247: Only wake consumer while polling
a52f4159 GH-1226: Update snippet to correct return type and misspelling
43ddbf12 Doc Polishing
2490dd5b GH-1234: Fix FailedRecordTracker [2.2.x]
3c816dca Try/Catch around error recovery [Backport]
fd2166e6 GH-1196: Use close(Duration) instead of close()

Change log:

3420ddc23323da7780758c3901163cdd2a0ccfb5 GH-1216: Move Transactions to the top level
ae51a9cbcd5d62936a35dac0e120c87de3ca7cb2 Upgrade dependencies, including Gradle
f359c6bfc2b2db55632babc1daf3550ff05e9853 GH-1226: Update snippet to correct return type and misspelling
dc03d982e32991e47bf47d783be1ef37a1f8a65a GH-1219: Assert no retry with batch listener
604eccee951e3136033c746475e336f7ef012267 KafkaListener javaodc polishing
5bdd7f8517af1b1070e23b4c077aea9281db7f14 Fix new Sonar smells
d614dada41eff9f49dc8e721bdfa2f72a7dbf8f2 GH-1210: Javadoc/Doc Polishing
5e45d04760f2dc330190af7e2c21103ee7cc7d77 Avoid BeanDefinitionOverrideEx with EnableKafka
cc1e19b6b0c1d3b8e36b534ac7276509459b9869 GH-1210: Add nack capability to MANUAL AckModes
04335d11269b66a27097f24edd90a557e7da3678 TopicBuilder Improvements
9766e42e6e22037534b3c3746973e54d0b9059fe Convert all tests to JUnit 5
8e4d96894615306db793a592386567d069b23014 Try/Catch around error recovery
b46397c3a8db83758fab63956133352f5abc796b Fix Sonar issues
64daa9d6ef9d410a363f2a8c345c56d1c2d1ca5b GH-1203: Extract ContainerProperties Super Class
f8f251fb11e22bd3d28a548fb79a204ccf91e3ec GH-1204: SIK docs for transactions
e53d43666657157b78cc64e7e9b0c9f9ae453b53 GH-1186: Add idleBetweenPolls container option (#1198)
1694690af89a1185a4b1b049d1f3abcdc5cdd257 Add BackOff to SeekToCurrent components
84187391ca04ef49e58efaa7d78b0b0c31e5d43e GH-1196: Polishing after backports
1e79bf1bc768678b1f7a0a66e94be4680aae9daf GH-1196: Use close(Duration) instead of close()
6b56103bdf6a1eaf133cf4e0196ef1ad8ef968f8 Fix new Sonar smell
1ccf14cdf43661d8c7fbc97090b59729ab7bf037 Upgrade Jackson version; use BOM for dependencies
325adc105a6034add14f488af29b7693c1012a47 Embeded broker - automatically set num.partitions
1d375a1cd1acbd49d1c7a0223d37cd846f584917 Fix default category in Log4j2LevelAdjuster
144042bab92cc075d1fef851c059e35e6adc9944 Back to Spring Snapshots

Change log:

c7eb2831 Upgrade Spring Versions
01c9bbaa GH-1168: Fix sendOffsets in local transaction
15ab1842 GH-1145: Backport NPE Fix
1171c004 GH-1134: Fix stop(Runnable) usage
96352b17 Upgrade Jackson
5950d62f GH-1066: Protect against null Headers
fa9cfa85 Fix close producers after a rebalance
f88cd9f5 Remove coment for Java bug since it is not anymore
8792bb3d Fix URL to SI Idempotent Receiver
6568be70 URL Cleanup
8e72b709 URL Cleanup
f8ade494 URL Cleanup
167a029b Add gateway links in SIK chapter
69cefe65 URL Cleanup
8947f497 Remove unused import
fe84fed8 Fix ConcMLContMockTests for current code base
2a708ba8 Fix ErrorHandler for Consumer Errors

Change log:

4f0f1d0e Upgrade versions to stable from snapshots
0c3ff71e GH-1171: Custom headers for ReplyingKafkaTemplate
2837fb26 Update assert messages to supplier messages
14157742 ReplyingKafkaTemplate Polishing
6f8127a3 GH-1176 Add java.net to trusted packages (headers)
159619dd Use @Configuration(proxyBeanMethods=false) (#1174)
0286e661 Set bootstrap servers property in @EmbeddedKafka
2ed89850 Bump to the latest BUILD-SNAPSHOTs (#1172)
3950995c Fix new Sonar smells
654d3bf5 GH-1168: Fix sendOffsets in local transaction
990d27dc Fix new Sonar smells
2a056124 GH-1158: Fix TopicPartitionInitialOff Deprecation
a68d5087 KMLC: Avoid many casts to ConsumerSeekAware
cb8cc1a5 Add seek helper abstract class
56ab0742 Sonar: processSeeks() reduce complexity
fe6ee5e4 ConsumerSeekAware: Add seek to time stamp
f4adf1e0 Streams config - remove unused conversion service
4f67c236 Fix Sonar issue - large anonymous class
a08f1b31 GH-1158: Deprecate TopicPartitionInitialOffset
d8afe76b GH-1159: SBFB: Fully deprecate StreamsConfig
48329076 Add relative seek to ConsumerSeekCallback
750f10ec Fix new Sonar smell
21441788 Use StreamsBuilder#build(Properties)
9342e191 testing.adoc example fix
868b6967 Fix link in whats-new.adoc
47cba219 Fix JavaDocs issues
7d0b110e Add RetryingDeserializer
bd6b7917 Upgrade to JUnit 5.5.0
74468cf8 GH-1151: Doc: Clarify Stateful Retry Recovery
762cd5e1 AckMode.MANUAL_IMMEDIATE - wake Consumer
4e5185cf Upgrade Kafka to 2.3.0; SF to Snapshots
fb53181d Fix Sonar smells in the FailedDeserializationInfo
6a3b8994 GH-1125: Add FailedDeserializationInfo
a770f7f9 GH-1144: Fix @EmbeddedKafka with @SpringBootTest
50c737e4 GH-1144: Doc. @EmbeddedKafka property limitation
a808a56c GH-1142: Add CompositeRecordInterceptor (#1143)
d85040a1 GH-1080: Add supplier for (De)Serializers
1d0ea100 GH-1139: Json Serialization: Add Fluent API
5ce4df90 GH-1137: Fix Json Type Headers for KStream
fee12060 GH-1134: Fix stop(Runnable) usage
7d79406d GH-1129: Add JacksonMimeTypeModule (#1130)
4ac551d9 GH-1126: Add delegating Serializer/Deserializer

Change log:

ed2d3c39 Upgrade Spring Framework, Data versions
f1662eb8 GH-1176 Add java.net to trusted packages (headers)
911c1187 GH-1168: Fix sendOffsets in local transaction
e2167ac3 AckMode.MANUAL_IMMEDIATE - wake Consumer
5fa86018 Fix typo in the ErrorHandlingDeserializer2
5fae3a92 GH-1125: Add FailedDeserializationInfo
020dfc91 GH-1137: Fix Json Type Headers for KStream
54a8588c GH-1134: Fix stop(Runnable) usage

Change log:

b99716cf Upgrade to Spring Framework 4.3.25, retry 1.2.4
56f43a8e GH-1168: Fix sendOffsets in local transaction
84514805 Remove @Nullable: it can't be at this version
03f14613 GH-1145: Backport NPE Fix
55a3fd5b GH-1134: Fix stop(Runnable) usage
6331d89f Fix close producers after a rebalance
73e71e59 Fix URL to SI Idempotent Receiver
c6a22f56 URL Cleanup
09cda40e URL Cleanup
84f6267a URL Cleanup
c0e9eee5 URL Cleanup

Change log:

022a8bc8 Upgrade Spring Data to Lovelace.SR9
b0b78055 Add ConsumerSeekAware Example
84efda31 GH-1121: Fix backported test
d3f13ef7 GH-1121: Fix KTU.getSingleRecord()
e487ece9 GH-1118: Add RecordInterceptor
d80ade57 GH-1111 Propagate the CMLC paused state on start
9d8adf24 Fix commit latch count
ebe4c9b5 Fix commitSync() calls race condition
a5bfe1b7 Fix re-pausing consumer after a rebalance
4ab4c8ad Upgrade Jackson

Change log:

693afce6 Revert new file added by mistake
db787fa1 Upgrade to Spring Data Moore RC1
27630d9d Reactor to stable versions in prep for M3
9fb778c4 Add ConsumerSeekAware Example
c7a78296 GH-1121: Fix KTU.getSingleRecord()
786c551a GH-1118: Add RecordInterceptor
a7a4df7c Add nohttp Gradle plugin (#1116)
b5822915 Doc: Change SIK What's New? to Newest First
32f5aa0c Fix Javadoc Typo
133514bc GH-1111 Propagate the CMLC paused state on start
369ffa68 GH-1111 Fix commit latch count
bdd89b6d Fix re-pausing consumer after a rebalance
7641bb50 GH-1109: Remove deprecated KafkaEmbedded
c906d0e0 Fix Sonar smells in EmbeddedKafkaCondition
6f4bb62d GH-1107: Improved JUnit5 Support
0cf87be5 Upgrade Jackson
88fa8fa4 Fix Sonar issue
a30fe051 Fix Sonar issue
8876c97e Revert "Fix Sonar smell for possible NPE"
22859b74 Fix Sonar smell for possible NPE
2fef0fc1 GH-1101: Overide transactionIdPrefix
02dc029d GH-1102: Fix KLEndpointRegistry SmartLifecycle
05d58916 Fix typos in Docs
97003ed9 Doc: Add Tx Synchronization Example
db8a86ff GH-1095: Add thread-bound producers
d78a0ead Fix deprecations and warnings
2ace8bf7 Add Tip for Assigning All Partitions Manually

Change log:

da29bd25 Upgrade to SF 5.2.0.M2, SD Moore.M4
6de3747b Check for null in ErrHandlingDeserializer2.close()
fc5d4338 ConsumerSeekAware default implementations
80388dad KafkaStreams <-> Spring Messaging
85fad6b7 Add missingTopicsFatal to container factory
17e2e808 Fix unused import
3953aa6b GH-1082: Dead Letter Streams Deserialization
f2d07ed7 Doc: Fix duplicate anchor
b55683ed HeaderEnricher: Fix doc link
78853ba0 HeaderEnricher: Add test using stream test utils
69a6ac35 Add Streams HeaderEnricher
fe214429 Add streams and streams test utils as test deps
16d3e736 Fix docs for batch error handler
2c5914ba Minor fixes and improvements
b10b068f Fix JavaDoc issue in SeekUtils
5c0f150a Use LogAccessor for logging
acc53af8 Doc Polishing
84b6f29f Fix typos in the AbstractKafkaHeaderMapper (#1077)
831521a9 Fix new Sonar issues
f20f0d65 GH-1074: Use AdminClient to check topic presence
f27a3ae7 GH-998: AggregatingReplyingKafkaTemplate
959b6953 JsonMessageConverter Polishing
8f69de9b Polishing
5155fcac SIK 3.2 Docs
97c081b6 Fix @since in Javadoc
a3a17c30 Use empty array in toArray call.
2446056f GH-1066: Protect against null Headers

Change log:

39f52157a2e4026912cfd250b0c027198c83c531 Upgrade dependencies; prepare for release
a587b134de5675c8d2bbe9238c0a3640ea3f93f2 Fix docs for batch error handler
40b21c1cd20f6443ccbb7f1f0c31e262eb294efb GH-1066: Protect against null Headers
04f4db38e24233d31ceadd5aa432bbd53d5fc066 GH-1059: Add SpEL support for KafkaListener.id()
95f7c67a8e3c6674a3510238dc88481c9dac3e1f Fix close producers after a rebalance
0a7f4a933ebacdcd334406f5fcec098011ab48c7 Fix generated doc location
5601017d7b4f7b39147fee639040259cc188d39b Doc update for scala 2.12