spring-kafka

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

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

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

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

84eec92cbf76f3e3ca0d26659343d51a10efa712 InvocationResult: Fix checking for null

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)

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:

2.2.0.RC1
2.2.0.M3
2.2.0.M2
2.2.0.M1

64307a2 Upgrade to SF 5.1.0; and others
507945e GH-784: Doc polishing
95d442a GH-804: EmbedKafkaCtxCustom add hashCode & equals
fd3efb7 Fix Package Tangle

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

Change log:

d8b4ba1d Upgrade SF to 5.0.9
950a9998 GH-800: Fix Zombie Fencing
db84b14e Doc: Partition Assignment

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

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

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()

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

Change log:

dc466ad5 Upgrade dependency versions
542c8012 GH-753: Close transactional producer on error
4811ea81 GH-686: Handle tombstones in Json Ser/Deser
24722241 GH-690: Propagate AfterRollbackProcessor to child
1558d290 Add licence and notice to all artifacts
6689bbb0 GH-683: Fix Transactions with ErrorHandler
0e901112 Doc 1.0.x client override

Change log:

3b767c32 Upgrade to Spring Data Kay SR9
4d7844eb Upgrade Spring Framework, Data, Clients versions
ab6970a7 GH-753: Close transactional producer on error
1056d3c4 Upgrade to Gradle 4.9
ece60309 GH-719: Exclude Spring 4.X dependency
a56469be GH-716: Null Payload Doc Improvements
2cd4d9dc Javadocs for ContainerProperties constants
40f76f08 Make ContainerProperties constants public

Change log:

903d6d1e Upgrade Clients to 1.1.1
2f0f65d6 Upgrade Spring Framework, Data to RC1
ac34b286 GH-753: Close transactional producer on error
63472ce3 GH-732: Refactor KafkaEmbedded for JUnit 5
6abc7ef3 Upgrade to Gradle 4.9
c325ad11 Valid class names in KafkaListenerEndpointRegistry customization docs
cadd61d3 GH-739: Custom (De)Serializer Doc Improvement
43a38614 Simplify assertions in MessagingMListenerAdapter
10db6e97 GH-650: Pause/Resume doc example
0ffccba2 GH-723: Relax reply template generic types
91f11598 GH-723: Relax reply template generic types
96245401 GH-734: MimeType headers as String
19460300 Add ErrorHandlingDeserializer
82322d4b GH-731: Replying template improvements
62a6f87e MessagingMessageListenerAdapter: Fix JavaDoc
d9c23e3c GH-725: Fix return Collection
d215f4d4 GH-719: Exclude Spring 4.X dependency
9ac47f6b GH-716: Null Payload Doc Improvements
7d85c56d Javadocs for ContainerProperties constants
d6c146b7 Make ContainerProperties constants public
a5125726 Fix varargs warn for CompositeProducerListener
8dc1dcdf GH-686: Handle tombstones in Json Ser/Deser
a9d22dc7 GH-690: Propagate AfterRollbackProcessor to child
8cfd24bd Typo fix for addTopics and doWithAdmin @since
91e0f629 GH-701: Support ConsumerRecords (@Klistener)
68951aab Add licence and notice to all artifacts
abba5117 GH-699: Fix line wrap
eee0b2fd GH-699: Fix Batch Listener with Kotlin
bcd6843b GH-693: Add BytesJsonMessageConverter
34172b64 GH-696: Add missingTopicsFatal container property
2355bdaa GH-691: Add CompositeProducerListener
55184505 Update JaCoCo to 0.8.1 (JDK10)
7a1653b5 ProducerListener Improvements
4563e320 More polishing - add Method to log
07a8b092 Polishing for previous commit
3a548276 Emit WARN log for @SendTo with void return
04110a6b GH-683: Fix Transactions with ErrorHandler
2ec0e322 Container factory doc polishing
1fa700ad GH-676: Allow to add topics into KafkaEmbedded
15facd03 SIKGH-204: Support auto config for all containers
6686e5ac GH-598: ConsumerFactory default methods
be073a8d GH-666: KafkaEmbedded doWithAdmin, addTopics
5fe9d5df Improve exception message with jar mismatch
6116966b GH-667: Fix BatchErrorHandler for generic errors
8c8a9aea Docs to 2.2 - Kafka/SF versions
141a1ce2 Doc polishing
5f324d78 Add Kotlin test case
bfccd924 GH-661: Close Producer after beginTransaction fail
83e3a451 GH-656: Fix seek on rollback
f79848b3 Fix Docbook sourceDir
ce9df8a2 Upgrade to Gradle 4.7 and others, build polishing
ad28b918 GH-652: JsonSerializer add null check for Headers
fd694470 KBGH-356: Fix thread naming with no bean name
f715bbef GH-646: Avoid sync when no transaction
42e2d010 GH-646: Transaction Improvements
9f724ea2 GH-640: Upgrade kafka version to 1.1.0
b048aaa8 GH-550: master to 2.2; fix tangles
e6985e81 GH-642: Increase test timeout
ba0faa45 [artifactory-release] Next development version
15d9cecb [artifactory-release] Release version 2.1.5.RELEASE
d408c27e GH-637: Fix spurious nonresponsive consumer events
3706405e GH-634: 1.1.0 Client compatibility
e77e1efb GH-621: Add KafkaStreams customizer
202f73cf Change log-compaction url
20635b80 GH-631: Fail fast with missing required group.id
506ba357 Fix typo in invokeRecordListenerInTx method name
1bef976b Fix typo in the KafkaListenerErrorHandler
48b3780d GH-618: Add StreamsBuilderFBean#getStreamsConfig
62594aeb GH-623: Fix AckMode.COUNT
6d3eb9aa GH-566: Ack Concurrency Issue
b0be198a GH-614: Fix general consumer error handling
5c78c30e GH-597: Add default impls for listener methods
9be96d5c Some code polishing for optimization
be689a3e GH-609: Pause/resume polishing; events
522f6b48 GH-601: @KafkaListener: Support List<Message>
6bd58b2b Catch exceptions thrown from error handler
17e255d7 Deprecate JsonDeserializer.DEFAULT_VALUE_TYPE
1d080e71 Upgrade to kafka-clients 1.0.1
c9f24b0a GH-599: Fix initial seek
12c1ad22 Support JUnit5 in tests