spring-kafka

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

Change log:

e2f8346efc48a66c3ca637cb8161462538e53b34 (HEAD -> master) Upgrade dependencies and Gradle plugins
01154a9dd0bcd8dbe8a3dd683177812a47e4293d GH-1008: Use transactional.id config as a prefix (#1065)
b00f54248898f6fec17527fa50d3e76c0fc75114 GH-1059: Add SpEL support for KafkaListener.id()
535c573c68d118e0d7322e1e31e49a2f53f75d34 (GH-928) Fix close producers after a rebalance
0d5495f9f54e56a4bcbb9e330930af2e84945d5b Upgrade dependencies; prepare for release
691b9ab62268f42d7a5663dd01a468316e830ee4 Fix Sonar issue
1ae44dae4a72aca1ef19a1d50d8c34ab69029367 Doc update for scala 2.12
a4c48a1a68823af1b0e1872cf3a9c172c5520248 Upgrade Scala to 2.12
596df202a39c0a7a2428d013221e240e26bef7a2 Pull isTransactional() up to KafkaOperations
3d451fdb4743d3a06bc8b68dde5a4bf9349ee379 Add getter for template producer factory
6d2bffa9e061dbaad1b1bd5c281d698b31de3488 GH-1055: Add TypeReference support to JsonDeser
f76b5e953f413457578ba7cca8d4ba4b3cffccb6 Fix new Sonar smells
c2a4c1e1e7e804ec12ff155f84a676844a06d30b GH-680: Use enhanced ObjectMapper by default
9909bf67c582553c99345e6ed2be644c2623f9a0 Fix typo in reference
94845f3d87ed1fad0d558d30c1415accff4718d0 Fix method complexity and NPE dereference
8dcc7e7303b3993ecf54bc1fe33516b45f5fcfc4 Fix new Sonar smell
c53c68e945b54e31a7da43152f315192c3c119e3 GH-1026: Support KafkaHeaders.GROUP_ID
4f1c90e9b80104ac5fa18d3e8d7333152cb30730 Fix new Sonar issues
9a21bcc712e64444b565ed42750ef564d84a550e GH-1027: Set ackOnError to false by default
dc28e2fc630d288fda41c6131eecb2408273c34c Fix JavaDocs for constants
95ccdcb5d7de4f5076878c4641d4171c786048f2 Doc updates for 2.2.0 clients
3f886930597a4877ada9d7960ea1459351de7f92 Add group.id to container info logs
4d4eb8046db13346c79e3123a0351a0315b7e7d4 Bump kafka-clients to 2.2.0
06c34c572f2916b7717d9865edb1adbbdafd6d61 GH-1014: Fix setSyncCommits Javadocs
6acd21eb0a97c2856f76a1e0e535482611443949 Fix license URL in SimpleKafkaHeaderMapperTests
b0dbea842d0ed270c9145fb89cd9b868b57d09c4 (polish-urls-apache-license-master) URL Cleanup
7122c4092053531592a445bb179c736ba557b3d0 GH-1012 Allow raw Strings in default header mapper
1ea3d05fd8717c63ff60d12ff2e31940ee951941 Fix URL to SI Docs
b4d51b1511a2bbc478326eb53817b952636fbccd URL Cleanup
4c6c4074501a45fe77da87bd3992c8be92183fc5 Add gateway links in SIK chapter
b7b830b8e27080d274ecf7f5dac27e164261b652 (polish-urls-xml-master) URL Cleanup
15750b9a089fb8d7060e30d9c45ddc5e19906bec GH-990: Polishing
1a41ac69f7790822926d9805864e16d84b9fda7a Polishing for coverage commit
53f5667d051145437ef4aee71786a25378f0e76d Fix Sonar smell for consumerPaused property
27a7690542ac2641de8158073799032f6b5c1c25 Improve container test coverage
764509d4d98ea0a999e234d9ac6201b31d99df7d GH-995: Close ObjectOutputStream in EHD2
f5b6927cdb5344c7d5e31c205285e95b09cebd92 More FailedRecordTracker tests
7d1e5401e4adfb5529c5c1ec1d190c18e0960764 GH-992: Fix SeekToCurrent zero retries
6ac6d24b7f32bc54787b02c8a8892ad45eb5bd0f GH-990: Run AfterRollbackProcessor in Tx
9763e637cd338dc2c7dcf6c31d724b19913ad1e7 (reactive-kafka-operations) GH-43: Add reactive operations for Kafka
0270df16477c44d01fca8f4110de8d700c0b5378 URL Cleanup
6e702f24ca717dba0c5a2b76d3171c3a9112c4b1 (spring-operator/master) GH-987: DeserializationException and dead-letters
d31e4d6d1b93731aa64d1e009e4505189db6a0c7 GH-983: Seek remaining records
495e53b93396457ef757e6e0f1b7667591f2b73c Fix Sonar smell for unnecessarily local variable
642db107b1c7305c7909d4ec884ace1d35b00a92 GH-983: Add exception classifier to the Seeking EH
9e86163647217dd9cefb5e35c974eb476cefc150 GH-981: Add StreamsBuilderFactoryBeanCustomizer
814ce546c00f4a3de3edd77c851451d612112d0a Fix hidden field in KMLC
4b1ed05b3b93987ff4eda34f4a4fb193724b4b2d Add TopicBuilder
637738b60d5cb2ab1f31ccbd17e856b9643b8fc2 (GH-945) GH-945: enable.auto.commit=false by default
1eead9d90430cfbe3e961e5db08bac2a0b92450e Fix new Sonar issues
fe170ee2b0b18e9e68ba9005ae66f2061f427c97 GH-974 Batch listeners replace KafkaNull with null
dbbc958412a01d13cf26b295b2465c5137350cf8 GH-781: Add commitSyncTimeout container property
5d0081bc24f782e56ac1c9f72be37d609b983e04 Fix Consumer Property Overrides
53f357dbb3a1a30e95664b96cba2744a24ce58b6 GH-970: Add getGroupId() to containers
dfd7c7a01017b81d3151bd26d425f296f06df15c GH-897 Docs: wiring Producer/Consumer interceptors
9dccd38b1f75f974a9162e6bb7581b9564bea4ad Fix some typos.
b5f22728167443705611b4b2fc297a0a3a366240 Upgrade kafka-clients to 2.1.1
47397fcc15a491ca0d13cfbc47c68448dbfbbc01 Ignore sync warning in SBFB
c476a75ed84b184d41b1ef187c0f6ceb6f54eca7 Fix JavaDoc & Sonar in StreamsBuilderFactoryBean
0858faebe14d1bb6d4bebfe80082a5545e76b691 Fix constant vlaue reference in JavaDocs
2dd226506aac92cb6e77f8a0e4586278bc319ee1 GH-950: Always wrap listener exception in LEFE
64cff66c79b7d7b236b29960726f86c92d119e33 Remove uses of deprec. Extended(Des|S)erializer
acdc2686203e634d6ecbcc3bf40e973124989179 Upgrades and doc fixes

Change log:

cca6fc125c7b0010e6fece0233c00d2988295a5a Fix Docs typos
2d9e92e2319933bd1ebf6035e73e995c4c024d86 Upgrade dependencies; prepare for release
fddbafe34a1ad24d940a37a878450f9e6682f0a6 Add getter for template producer factory
1241e9b68d7c95aaa8c7d2808c3610de3a7f8484 Fix URL to SI Idempotent Receiver
8e9a648f96ca7ee1d66e3bc46a6cddfa408bee9b URL Cleanup
025ea4312936c173a6f619b003939be5cef84ac0 (polish-urls-xml-2.2.x) URL Cleanup
d4175f258f72a21f74fdda0812d8abe12f403a0d GH-1014: Fix setSyncCommits Javadocs
02de8a2e919149e9a0fad4b3e23ab77c202f4dee (polish-urls-apache-license-2.2.x) URL Cleanup
666fd5c6b0d3ee5b90bcdc7fd31e7b2bcb7efc1f GH-1012 Allow raw Strings in default header mapper
c56e8e7890b4638603b0402a18bd1e76e4f8020a Add gateway links in SIK chapter
60b3678e193a51af76f97dbedd6c0c6ab7f754e6 URL Cleanup
438693b666cc2729b64366eacdb12e613fac96ee GH-995: Close ObjectOutputStream in EHD2
6cabfe5b11a6abef631d1b30e5b51155a89ce6a9 GH-992: Fix SeekToCurrent zero retries
c226c9ee8bda4f28ee238917b5ab71f92f81c358 GH-990: Run AfterRollbackProcessor in Tx
2d8a094cf0c903c0e1466ec1d172ddbd33acde5e (spring-operator/2.2.x) GH-974 Batch listeners replace KafkaNull with null
46aea174a3b64e61257a6fc652c2ba5f6d042032 Fix Consumer Property Overrides
45ddac7fea68d5e0ffe309ff758c192f04d522bc GH-970: Add getGroupId() to containers
5a98a510d3d90de7b44dc2b21dae3800e743b484 Fix default deserializer getters

Change log:

20e514726f61ebe944740c14f7ace84219954fce Upgrade dependencies; prepare for release
c963a35ab61587d1297bd210cbae0d34de81badf GH-960: Fix Javadocs
7edf9f4f41446fe53832e54b1b034e8f9c5f369f GH-960: Seek-to-Current - commit recovered offset (#961)
3d8de782d7db373cd3c536c6817e1b47fc279123 Fix ErrorHandler for Consumer Errors
2414025e7b69ad1d98158d11604893afe79603f9 Reduce method complexity
ff174e0a952477e3ac486d607f1369b2550194fa @KafkaListener Consumer Property Overrides
c5b2ee47cb13d60357794e5bb1aeaa6fd1ede726 GH-946: Detect Unnecessary Replying Template
ee240006b3ddc2117ac5205a52f80000e094875d fix outdated references to DEFAULT_STREAMS_CONFIG_BEAN_NAME
64a8a7bb3ace2c817d6f9f1b55548d7fa1a5d468 Fix race condition in test case
f6caf5bb1efc13273dfa0f01179115462a580dca (modernize-docs) Update to the build file to modernize the docs
065c901e69b9767af87f9a18f7fd81499463fb4c Improve Javadocs for Topic Patterns
84a7a706abcc41eb1051da3c93ac87fcc159de90 (editing) Editing pass for spring-kafka
18836db8b578c6ea592a49b70de5944ce7d2976b (Boot_property_for_embedded_kafka) GH-948: Sonar fix
e39be7eeffcec1511d0338b47432e6f456d68523 GH-948: Decorate LEFE for batch listeners
2907f9cc51fc86f21900e8d203a6a7d7ee06051e GH-948: Enhance LEFException with group.id
cf6383891b75d580700b3692b3f85eab8d7cae54 Fix typo in KafkaListenerErrorHandler class description
39ce0826e0b9b9a12c6dbfe2e3923523c6b64137 Update issue template
71f476716be6e941a815c09077ca2843ad2320db Fix new Sonar issues
ab344af41a7a00167f3258711d8e0ae1400afaf5 Introduce KafkaStreamBrancher
c0398abbf409a191ebc2afb240f53b402e184e0d GH-942: KafkaAdmin Improvements
32063e4ab2c5c9e835a2b7432b3411d0db2bfaaa Fix BatchListenerConversionTests
bda5d99717ba8afdde32f9e17d00179d198e9e9e Polish doc
9a73a4a2021b0ceaaffb62cc1759338c78124754 GH-787: Fix upper-bounds for generics (#937)
4c6d6f576778b9696b6a91fdddfb7b056f6689f6 GH-917: Specify the port with @EmbeddedKafka
25151c095d2c2d09e00291ecf15f790ccb9f72f4 Updated README.md code of conduct link
dca2761b71059c8a0195c2d22fa661a4acecdc7a Upgrade spring-retry