spring-kafka

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

Change Log:

b80fbd46 Fix varargs warn for CompositeProducerListener
4fe846d2 GH-686: Handle tombstones in Json Ser/Deser
62e9325d GH-690: Propagate AfterRollbackProcessor to child
c4bf5791 Typo fix for addTopics and doWithAdmin @since
c731e617 Add licence and notice to all artifacts
9d167b75 GH-699: Fix Batch Listener with Kotlin
45223425 GH-693: Add BytesJsonMessageConverter
ca657274 GH-691: Add CompositeProducerListener
221ead50 ProducerListener Improvements
99ccc2c2 GH-683: Fix Transactions with ErrorHandler
9307dcd9 GH-676: Allow to add topics into KafkaEmbedded

Change Log:

d83692c Upgrade to SF 5.0.6
8694007 Upgradle Gradle to 4.7 (2.0.x)
30a5ee6 Don't use JUnit 5
f34ad5f GH-661: Close Producer after beginTransaction fail
7d22fc0 Fix incompatible with caller stubbing
439f2a5 GH-656: Fix seek on rollback
21fcb11 KBGH-356: Fix thread naming with no bean name
23e97a5 GH-646: Avoid sync when no transaction
1529a42 Fix Checkstyle violation
2e32362 GH-646: Transaction Improvements
0589bea GH-642: Increase test timeout

Change Log:

9ddfd52 Upgrade to SF 5.0.6
92c77b3 GH-666: KafkaEmbedded doWithAdmin, addTopics
75375f0 Improve exception message with jar mismatch
66753f3 GH-667: Fix BatchErrorHandler for generic errors
dbfa272 Doc polishing
c5c2765 Upgrade Gradle to 4.7 (2.1.x)
f48ad87 GH-661: Close Producer after beginTransaction fail
9612e88 GH-656: Fix seek on rollback
1f3d7cd GH-652: JsonSerializer add null check for Headers
19ea7f1 KBGH-356: Fix thread naming with no bean name
82eb21f GH-646: Avoid sync when no transaction
1b53c4b GH-646: Transaction Improvements
e6985e8 GH-642: Increase test timeout

Change Log:

0a27d14 Upgrade kafka-clients to 0.11.0.2
7793c0b Upgrade to SF 4.3.17
010c3e8 GH-661: Close Producer after beginTransaction fail
e826a58 GH-656: Fix seek on rollback
877fd6a KBGH-356: Fix thread naming with no bean name
1e55d7d GH-646: Avoid sync when no transaction
79510ec GH-646: Transaction Improvements

Change log:

d408c27 GH-637: Fix spurious nonresponsive consumer events
3706405 GH-634: 1.1.0 Client compatibility
e77e1ef GH-621: Add KafkaStreams customizer
202f73c Change log-compaction url
20635b8 GH-631: Fail fast with missing required group.id
506ba35 Fix typo in invokeRecordListenerInTx method name
1bef976 Fix typo in the KafkaListenerErrorHandler
48b3780 GH-618: Add StreamsBuilderFBean#getStreamsConfig
62594ae GH-623: Fix AckMode.COUNT
6d3eb9a GH-566: Ack Concurrency Issue
b0be198 GH-614: Fix general consumer error handling
5c78c30 GH-597: Add default impls for listener methods
9be96d5 Some code polishing for optimization
be689a3 GH-609: Pause/resume polishing; events
522f6b4 GH-601: @KafkaListener: Support List<Message>
6bd58b2 Catch exceptions thrown from error handler
17e255d Deprecate JsonDeserializer.DEFAULT_VALUE_TYPE
1d080e7 Upgrade to kafka-clients 1.0.1
c9f24b0 GH-599: Fix initial seek
12c1ad2 Support JUnit5 in tests

Change log:

7bd19fd Fix KafkaMesListenerContTests for proper mocks
b688311 GH-637: Fix spurious nonresponsive consumer events
15cb937 Change log-compaction url
9b79bff Fix typo in the KafkaListenerErrorHandler
c0db1ce Fix KafkaMessageListenerContainerTests
c56365e GH-623: Fix AckMode.COUNT
7105774 Fix KafkaMessageListenerContainerTests
e08854a GH-566: Ack Concurrency Issue

Change log:

ebbe5f0 Fix KafkaMesListenerContTests for proper mocks
4c5399d GH-637: Fix spurious nonresponsive consumer events
6943d5f Change log-compaction url
398967f Fix KafkaMessageListenerContainerTests
8a83135 Fix KafkaMessageListenerContainerTests
e7e6c9d GH-623: Fix AckMode.COUNT
5e877a8 GH-566: Ack Concurrency Issue

Change Log:

e5f4f6b GH-642: Increase test timeout
33e6848 Fix ListenerContainer to assert KafkaDataListener
161b367 GH-439: Container Lifecycle Fixes

Change Log:

09fa5c4 Dependencies upgrade
1540092 SIKGH-198: Add pause/resume to Listener Containers
6a41127 GH-561: Use different header for JSON key
60f92c8 Add ChainedKafkaTransactionManager
b25e144 GH-563: Add default @KafkaHandler
56db7ea GH-582: Use a truly random port in KafkaEmbedded
655cbee Embedded Kafka SeekToBeginning if needed
74e5956 More tracing and debug logging
9d3e326 Expose KafkaTemplate.transactional accessor
114f409 GH-566: Use ConcurrentMaps for offset management
3716111 GH-568: S-I-K Gateways Documentation
31431fa More Spring Integration Kafka Support
5944e17 Replying template - add getter for reply topic(s)
94d4fce GH-555: Resolve PPs in EmbeddedKafka topics
fc6ae37 Fix sample code in javadoc of EnableKafkaStreams
5adf2d1 Add KafkaTemplate Request/Reply support
0d09e8d Support stateful retry
4505874 GH-548: StreamsBuilderFactoryBean enhancements
3771e2a Fix @SendTo Runtime SpEL Detection

Change Log:

9c255d6 Upgrade to Spring Framework 4.3.14, Retry 1.2.2
52b195b Doc Copyright to 2018
4968758 Remove logger from KafkaEmbedded
88a28ce Fix KafkaStreamsBranchTests for Kafka-0.11
37d35fe GH-539: Wait for partitions from embedded topics
ad4e4cf GH-522: Fix NPE in listener container (#524)
d978246 GH-511: Committing offset immediately on error
ad09778 Fix NPE when Jackson not present

Change Log:

0ad14ba Upgrade some Spring dependencies
e5cb71c Doc Copyright to 2018
a62128c Fix KafkaStreamsBranchTests for Kafka-0.11
8a11dae GH-539: Wait for partitions from embedded topics
6d45eb0 GH-522: Fix NPE in listener container (#524)
b7acbb3 Fix Checkstyle issues
225d27c GH-511: Committing offset immediately on error
dafea32 Fix KafkaAdminBadContextTests

Change Log:

986042a Upgrade some Spring dependencies
e3d4129 Polishing for StreamsBuilderFactoryBean
b178176 GH-537: Configurable log level for offset commits
63b2bcb Configurable KafkaStreams cleanup execution
2526509 Doc Copyright to 2018
6b74d8c GH-539: Wait for partitions from embedded topics
cbf6762 Doc Fix
eb4eca2 Support local bean reference in @KafkaListener