spring-kafka
Provides Familiar Spring Abstractions for Apache Kafka
APACHE-2.0 License
Bot releases are visible (Hide)
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
Published by garyrussell almost 6 years ago
Change log:
81be7876 Upgrade to Spring Data Kay SR4
1997c768 Better generci types in JsonSerde/JsonDeserializer
5fa31c33 GH-926: Fix error handler detection
f4a0a239 Fix test
2ef2ed54 Upgrade Spring Framework to 5.1.4
14c2a309 GH-926: Always Detect ErrorHandlingDeserializer2
132934d2 Upgrade Jackson version
6d05a03e Doc: Add anchor for annotation properties
7cd9f103 Increase EKIT test timeouts
88869e6a JsonDeserializer Header Removal Polishing
43fd291c GH-916: Fix RemainingRecordsErrorHandler
cf6a7851 GH-915: Fix JSON default object mapper config
7c512c90 More Sonar polishing
1be02a21 Sonar polishing for previous commit
e7c8be39 NonTrustedHeaderType header propagation
e398d344 SI Outbound result channel docs
95ebeb6d GH-908: Fix test
2f4630b4 GH-908: Don't cache dedicated consumer producers
9fef537b GH-906: @KafkaListener Javadoc Improvements
b2799450 Process errorHandler in class level KafkaListener
a2255b83 Doc polishing
d62e3071 Sonar fix
4089c6a2 GH-900: checkstyle
ddb2c439 GH-900: Sonar polishing
8f26bfbc GH-900: Use correct txId for initial commit
c077b1d7 GH-894: Use context CL in the JsonSerializer
e22527f0 Add a missing closing pointy bracket in doc
b4625516 Polish Replying Template config with Boot
dcb6eadb Upgrade kafka-clients to 2.0.1
56b0e937 GH-892: Reinstate MimeTypeJsonDeserializer
Published by garyrussell almost 6 years ago
Change log:
c928287f Upgrade to Spring Data Kay SR13
f722079f Upgrade Spring Framework to 5.0.12
40713e65 Upgrade Jackson version
b9461628 Fix missed cherry-pick change from previous commit
a1eb851a GH-916: Fix RemainingRecordsErrorHandler
4831560c GH-908: Fix test
43305367 GH-908: Don't cache dedicated consumer producers
ad35cb8e Fix Test
4e5b2338 Process errorHandler in class level KafkaListener
8820b46e GH-900: Use correct txId for initial commit
Published by garyrussell almost 6 years ago
Change log:
777d6b1b Upgrade Spring Framework to 5.0.12
0dcd3389 Upgrade Jackson version
e58e68ee GH-908: Fix test
669e48f1 GH-908: Don't cache dedicated consumer producers
e36d458c Fix Test
8fe9406c Process errorHandler in class level KafkaListener
87ec5829 GH-900: Use correct txId for initial commit
Published by garyrussell almost 6 years ago
Change log:
209222b9 Upgrade Spring Framework to 4.3.22
1555ea48 Upgrade Jackson version
0a140eb3 GH-908: Don't cache dedicated consumer producers
9e3bd8c7 Process errorHandler in class level KafkaListener
d9248b68 GH-900: Use correct txId for initial commit
Change log
1f8f088704284810851ce52ccc76de847acf3c09 (2.1.x) Upgrade dependencies
e86380771c4169b7d03e7ca2845eb94f49f367d3 Add import for @Nullable
13fe69fef9e00d80dfbab35ceae338f37ea6d280 GH-881: Null check in closeProducers()
d0b2051accf5f7c1e5fa1cb6971437327028dd77 GH-869: fixed NPE in case of array target types
62ce1ca2965b27dfe56603ea8cb397f449f8710e GH-842: Fix NPEs in KafkaListenerAnnotationBPP (#864)
3d2f1ed880285bbc49c55ff4c87d8c8d48500bcc GH-859: Fix nested transactions
e895eb2f876b9a6bcca142d0b46a972d53cfadcc Fix the previous commit
20cbb8b57de8dadc680e2e2be3fb5f5e64bf9854 Log TX Exceptions
e8cafc178413583e504d335b1ddc2c70ec885af5 GH-847: Support placeholders in @SendTo
f32a1b80024c074d97b89ab73148f7481825864b GH-840: Fix typos in documentation of Filtering Messages and Retrying Deliveries
a7c453bb4bb5feb7713cb3758440c14e3a6baed5 GH-834: Remove transactional producers
d415392f822c759717fdf5d91ddcbd47516e1e58 Update documentation on KafkaListener annotation
aa400fa4b8f6b015b6e7d3af2ec0c2f7b52632d2 Doc polishing, remove connectionFactory
16f3d8c99d7a351e92c3af3343542c2b145ac33c GH-813: Re-pause a paused consumer after rebalance
98af3e69004ad7e1dcaeeebf6ea537900b797b04 GH-804: EmbedKafkaCtxCustom add hashCode & equals
Change log
d02efbf3bb02907b9a98993fbf7350605e4cb16d (HEAD -> 2.0.x) Upgrade to SF-5.0.11.RELEASE
d6f2f4c93608ceba9dcfe3eb0080783afee2d1f5 GH-881: Null check in closeProducers()
66a716296c540194c9a521f542f466b66e7e88b3 GH-842: Fix NPEs in KafkaListenerAnnotationBPP (#864)
6bd46944e9b5c69c5a94c0fc5c91b71519262492 GH-859: Fix nested transactions
addfacaf4942b73ce1d6c1b4d28523434af97d0e GH-840: Fix typos in documentation of Filtering Messages and Retrying Deliveries
bbd2b9941f9e9f933ca595c13690d4ccb5ceb0ae GH-834: Remove transactional producers
4037ca5ee0e5ef549fd989927ec4594e8888e6a7 GH-804: EmbedKafkaCtxCustom add hashCode & equals
Change log
b69a4534c3c0cf9ca2edfd99e973382f9660cdd9 (master) Upgrade dependencies & fix lambdas for method ref
4390405eff55a4ff596c00596f53a5534f4088b6 Add appendix for 2.1.x kafka-clients jar
6c79d952e6f82c06073843a71646de78d20765c8 GH-878: Polishing - Fix new tangle
0a953b0e51a6334ac2954e153d85836c6236b117 GH-885: Restore infinite retries STCEH
04e9e1a2b3c09edffa642f9234c5af05665bb3b2 Sonar Fix possible NPE
810529a978324eb4baae62365589a28772d9bdf4 GH-854: Docs about Filtering Batch adapter
45b5d8b1be788411cc01bb6d6e31d5f18d1de541 GH-878: Add parent container to container events
7859b395248932d986a58ebffbebd75d13924704 GH-881: Null check in closeProducers()
fd0fbaab9ab6f6a65fd88454c0f5eff09818f410 Add Docs for @SpringBootTest
8cc633eaf33d9ae64b3b5285aabb2d4d709518d0 JsonDeserializer: Fix CTOR overridable method call
6166437cdc3f087313e933e5e7f04d339b6e2c99 Resolve Sonar false positive
de6d1e475ee4de16ef874ebed4ca8462bc03e762 GH-869: fixed NPE in case of array target types
8eaf6827e3651dc34e385afe7b30d0939834db6a Sonar: Resolve remaining code smells
39f2f54e7727b4a64ed5867bbb22a03fb531982c Sonar: static field name format exemptions
58013ed46c11f39ce1d0c3a7e1549a3aae3d507d Fix unused imports (Javadocs)
283aeee54d79e7e42747dce7d3af746f5cb6e6d1 Fix Javadocs for the previous commit
ff5f4f204b36ed02b3aa5d96445f3d51a73106d4 Sonar: Fix classes with B,C maintainability
00928e2fa3c8abb4175aedfd49e438e061d05a3c Address several Sonar issues
c5f485d2dd6192414bf58a28b1a509a68288e675 GH-867: Add ConsumerStoppingEvent
cf9daf538eb097d54509f4685e38662e9b8289b4 Fix new Sonar reports
a4a0b861864d96c69a03fd2b2a42c716a2258c73 Address various Sonar issues
bc929b8ec9033edf382486ddeef9f14f1c4204f8 Address Sonar reports for recent commits
3f17a9f041f2bf967662e40fc1c23f0a34cb3d59 Fix Checkstyle violations
4cdaa94a5b06b4fe919adffd43559f4b9b3fd378 GH-842: Fix NPEs in KafkaListenerAnnotationBPP (#864)
f5c0a58a305c928af1ffbcd3d3518e7062e2d437 GH-850: Stop container on error
0bd45650dcc93fecb0a35ed73e80243161f6f06d GH-855: Dead letter publisher and transactions
035a3b1f658e6acf2f6c0a7c1d3f5083b0b111a6 GH-859: Fix nested transactions
074e9613e28fdba73c560be3748bac501ea799d2 GH-853: Type Safe ErrorHandlingDeserializer
7bf2c647ff26f49ec8b88ec2c754fb7b379a0136 GH-862: Fix docs for ErrorHandler
56f5bfb8c552b3265e9f111f3148db9361492584 Add Samples
5ce42d2e42ee06c6610c869d12fc3dc76903f7f3 Sonar: Improve test coverage for recent commits
f8ea5bc5b3034ae1ae542e69e4b1e25410882edf Sonar Polishing
87a1b9988e69a049e57ecbb2dc4256bfb50b4fdf Log TX Exceptions
d19189eea2161475c090ed1ea3dd0bcd8d0cf81e GH-847: Support placeholders in @SendTo
1dc1eef11678f1493e6c48e0cf3f0d6d5d259f5e Polish InvocationResult.toString()
228d25b0f99722a34382433f79f700829d4a65d3 GH-843: Make ErrorHandlingDeserializer as generic one (#844)
Published by garyrussell almost 6 years ago
Change log:
c9ffc7a9 Upgrade to SF-4.3.20
be0cb65a GH-881: Null check in closeProducers()
c2a125db GH-842: Fix NPEs in KafkaListenerAnnotationBPP (#864)
a50a2a94 GH-859: Fix nested transactions
9c9a200c GH-834: Remove transactional producers
7517916f GH-804: EmbedKafkaCtxCustom add hashCode & equals
Change log:
ac2191c434f855c7444e1d5f9587e6f25c8f09b5 Doc fixes
bcf5a6aafa367dee0d5939c8ad4a7688f0487982 GH-840: Fix typos in documentation of Filtering Messages and Retrying Deliveries
a0342ccfebb5e7ac58a311491745635fdee67c1d Upgrade to SF 5.1.2,RELEASE, SD 2.1.2.RELEASE
d6bc23878f6bbebe9cbbd2f3a2f036b3e9c164c8 Upgrade SF to snapshot
a6c0a8223eae739ce05e14a8d9ab868a11fe41ec Clarify listener endpoint registry bean
8ce3aa2eb8d62ce3f51dbf37d153656b90e2b6d4 Sonar fixes
93558fdd3c58f0dd8caa8799f8a7a4ad725ab53f Fix unused imports (Javadocs)
7b214f886b45cc22e143313de508e0ec074b8b30 GH-834: Remove transactional producers
1783e8cf96e2fe8926d9ce761ec5f8b6bcdd772f GH-835: LCF: check error handler is the right type
5731d7699c029039268335ccd91028966ba531c9 Sonar Fixes
55b16f1f1bab4fb793e2d11c791dc78740f29939 Fix DEBUG error message about reply topics
e0e013e808cb455305b70f91a1e42dff42c8b30c Update documentation on KafkaListener annotation
1b5b5b234f568f3f1764a3f90a1a444d2cabd961 Fix Checkstyle in the MessageListenerContainer
adc94630582dc037cce5b47745093d247632d605 (ektopics) Embedded broker support different partition counts
2502a8fe1c9759eb78092bca5a1ff6620006c021 Doc polishing, remove connectionFactory
996f8649d562cb7a2b15af42ab0bea64b510d961 GH-811: Configurable Reply Headers
214316839b2e309151094301016e7fd66d2c08c4 @KafkaListener Add BytesToStringConverter
265a4d3279a7345754e81795326d25b8e093f0da GH-816: Simplify Validator configuration (#824)
012215c145e7e6506410fe6ba679962bae615cb7 GH-813: Re-pause a paused consumer after rebalance
c5294f1af67e54007c5ae09cd4d0f7834f7ed2ef KafkaStreamsConfiguration Conversion
eaae2ffdf594d31af51b99e701667df57476c9ac Fix InvocationResult.toString()
f68d2bd456a1786699e857e182d72114e0cc2316 INT-4536: SIK Tombstones Docs
99a25221ba7f035cfa6561949abf0eaaecd80ebe GH-812: Support @AliasFor in @KafkaListener meta
afedef4b01292b6886dd5a21399c6e0d43aa8e5e What's New Kafka-Clients Version
Also see change logs for previous Milestones in this version:
Published by garyrussell about 6 years ago
Change log:
9fae369c Upgrade to SF 5.1.0.RC3
2b78b42f GH-800: Fix Zombie Fencing
76f7ed72 Fix @since tag for setRemoveTypeHeaders()
7beaa606 GH-794: Json Deserializer - remove type headers
9f828a85 Doc: Partition Assignment
e16ae4fc SeekToCurrentErrorHandler and Recovery
9997ffdd Refactor KafkaAwareTransactionManager
b3f3894d Add ISSUE_TEMPLATE.md
1247ee14 GH-786: DKPF: ContextStoppedEvent
Published by garyrussell about 6 years ago
Change log:
d8b4ba1d Upgrade SF to 5.0.9
950a9998 GH-800: Fix Zombie Fencing
db84b14e Doc: Partition Assignment
Published by garyrussell about 6 years ago
Change log:
98c74181 GH-800: Fix Zombie Fencing
4718c326 Doc: Partition Assignment
e7a12066 GH-777: Reset running on stop()
a7f75aef GH-782: Fix GenericMessageListener Javadocs
111b4c1e GH-774: Rethrow e in KT.executeInTransaction()
5a93acea GH-753: Close transactional producer on error
6d456ea8 GH-719: Exclude Spring 4.X dependency
02d4a45a GH-686: Handle tombstones in Json Ser/Deser
ea52aca8 GH-690: Propagate AfterRollbackProcessor to child
d5fd2c8b Add licence and notice to all artifacts
c5aaef56 GH-683: Fix Transactions with ErrorHandler
Published by garyrussell about 6 years ago
Change log:
b17c530f GH-800: Fix Zombie Fencing
48caf238 Doc: Partition Assignment
f99c74ab GH-777: Reset running on stop()
452814c9 GH-774: Rethrow e in KT.executeInTransaction()
2daa46ca Doc fixes
Published by garyrussell about 6 years ago
Change log:
5024a77a GH-777: Reset running on stop()
ad4214d0 GH-782: Fix GenericMessageListener Javadocs
ddd4b460 GH-780: Fix typo
b9916eee GH-780: More 2.0.0 Doc Polishing
564ffc28 GH-780: Docs for using the 2.0.0 clients
cc3d4214 GH-780: kafka-client jar 2.0.x with KafkaEmbedded
f9f7d9c5 GH-774: Rethrow e in KT.executeInTransaction()
Published by garyrussell about 6 years ago
Change log:
57e80214 Polish KafkaTemplate.executeInTransaction()
79c46c3f GH-777: Reset running on stop()
0ffcfe06 GH-782: Fix GenericMessageListener Javadocs
280cc4c2 Upgrade SF to 5.1.0.RC2, SD to 2.1.0.RC2
217ada73 Tx Javadoc Polishing
29df442f Add KafkaStreamsConfiguration
b115a312 Spring deps to B-S and Fix @EventListener tests
c59a31fd GH-774: Rethrow e in KT.executeInTransaction()
43a8b2da 2.0.0 (Streams) Doc Polishing
b845fbe3 Fix Javadocs format violations
7d4af6f6 GH-767: Add DeadLetterPublishingRecoverer
9ae454a8 GH-769: Add JSON Type Mapping Property
0474eb9b GH-763: TX rollback and SeekErrHandler: Recovery
02129d9f GH-762: ConsumerStoppedEvent
82b816d0 @NonNullApi for core package
f15bf08a * GH-757: Upgrade to Apache Kafka 2.0.0
7d68d23c Fix Asciidoctor config/JSR305
ff2b413e GH-756: Doc polishing for the previous commit
9c40625d GH-756: Add concurrency, autoStartup to @KL
79826219 Fix embedded kafka javadocs, logger
