SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,579 Commits 28 Branches 0 Tags
605344d5a59df2d1d7447e5696961bb4e469ff7a
Commit Graph

3579 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
buildmaster
605344d5a5 Going back to snapshots 2022-07-29 19:05:12 +00:00
buildmaster
c69888ae68 Update SNAPSHOT to 4.0.0-M4 2022-07-29 19:02:38 +00:00
Chris Bono
aa3ab75f64 Remove stream-bridge-avro sample 2022-07-28 16:06:03 +02:00
Chris Bono
55c3f66c61 Remove kafka-streams-branching sample 2022-07-28 16:06:03 +02:00
Chris Bono
5f289a6d41 Remove kafka-native-serialization sample 2022-07-28 16:06:03 +02:00
Soby Chacko
6382326499 Add reactive Kafka binder to bom dependencies 2022-07-27 20:05:54 -04:00
Soby Chacko
ad520fff3f Adding initial docs for reactive Kafka binder 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2457
 2022-07-27 20:02:08 -04:00
Oleg Zhurakousky
b276d803d7 Address functionType and other deprecations 2022-07-27 17:56:36 +02:00
Chris Bono
482b945bfd Add KafkaStream interactive query sample app (#2461) 
* Add KafkaStream interactive query sample app

* Remove KafkaStreams interactive query "basic" sample app
 2022-07-25 18:07:59 -04:00
Oleg Zhurakousky
f1a0e76e80 GH-2452 Clean up bindings in Stream bridge once they are removed from cache 
Resolves #2452
 2022-07-25 16:37:54 +02:00
Oleg Zhurakousky
b9e30adf2f Wrap PollableBean in try/catch to accomodate AOT 2022-07-25 09:57:29 +02:00
Oleg Zhurakousky
88e5f88270 GH-2455 Fix the AOT Binding initialization logic 
This commit also includes partial work to ensure framework works in full native/AOT mode.

Also, PollableBean remains and will simply not work in AOT mode until https://github.com/spring-projects/spring-framework/issues/28748 is resolved. That said, i will be deprecating t and it will be removed in the next release given that we already have configurable alternative

Resolves #2456
 2022-07-22 13:53:51 +02:00
Chris Bono
59136c00d8 GH-2455 Add AOT support for binder child contexts 
Fixes #2455
 2022-07-22 13:53:43 +02:00
buildmaster
221c3e5b37 Bumping versions 2022-07-21 17:28:33 +00:00
Soby Chacko
ada56c4e0f Fixing Kafka binder build issues 
Update maven surefire-plugin to 3.0.0-M7 to address an issue
with how the newly added GlobalEmbeddedKafkaTestExecutionListener
in spring-kafka-test loads configuration parameters. The current
versions (2.x) of the plugin are not properly loading these parameters.

https://maven.apache.org/surefire/download.cgi
 2022-07-14 12:11:54 -04:00
Oleg Zhurakousky
f5f7e41010 Fix tests after SI update 2022-07-14 16:46:26 +02:00
Soby Chacko
89eb9a31d4 Code cleanup - Kafka Streams binder 2022-07-11 14:33:18 -04:00
buildmaster
bc72fc7155 Bumping versions 2022-06-30 17:38:59 +00:00
Chris Bono
0cb59496fe Make InteractiveQueryService only return used state stores 
This restores the KafkaStreams 3.0 behavior in this area.

Fixes #2445
 2022-06-25 22:09:19 -05:00
Pommerening, Nico
7554ff9bbd Kafka Streams binder health indicator improvements 
Fix KafkaStreamsBinderHealthIndicator overriding HealthCheck Thread Details to report full details.

checkstyle fixes.
 2022-06-23 14:20:04 -04:00
yiliu6
779ebfcf88 udpate outdated links and add link for service bus binder 2022-06-23 14:01:59 -04:00
Chris Bono
06ffe76c01 Improve KafkaStreams ineligible-definitions property handling 
* KafkaStreamsBinderEnvironmentPostProcessor respects existing ineligible-definitions
* Add tests for KafkaStreamsBinderEnvironmentPostProcessor
 2022-06-17 13:42:25 -04:00
Chris Bono
6d1be361fe Simplify SerdeResolverUtilsTests setting of ineligible-definitions 2022-06-17 13:40:19 -04:00
yiliu6
acc75183e2 Enable multiple customizers for binder and provisioner. 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2423
 2022-06-17 12:43:41 -04:00
Soby Chacko
21171914ad SendToDlqAndContinue needs to be excluded 
In Kafka Streams binder, we need to exclude the SendToDlqAndContinue
BiFunction by adding it to the ineligible function definitions.

See this commit for more context: 8ec15fa3ca
 2022-06-16 18:12:11 -04:00
Gary Russell
63fe90f793 GH-2434: Fix Docs Re: ErrorHandler 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2434
 2022-06-16 09:39:27 -04:00
buildmaster
97975a0d3c Going back to snapshots 2022-06-15 11:35:09 +00:00
buildmaster
84d4cccdee Update SNAPSHOT to 4.0.0-M3 2022-06-15 11:32:24 +00:00
Oleg Zhurakousky
225d96c4fb Temporarily disable failing Kinesis test 2022-06-15 13:14:24 +02:00
Oleg Zhurakousky
da3157c6d1 Remove dependency on test-support-internal from kinesis binder 2022-06-15 12:52:19 +02:00
Oleg Zhurakousky
c4f516e72f Change from SCSt version to project.version in Kinesis binder 2022-06-15 12:26:41 +02:00
Oleg Zhurakousky
9768586145 Fix batching test 2022-06-15 11:50:43 +02:00
Oleg Zhurakousky
2b914cd0f7 Update SI Kinesis to 3.0.0-M1 2022-06-15 11:39:49 +02:00
Soby Chacko
7b9c66c4ac Adjust KafkaBinder DLQ test error messages 2022-06-14 10:49:25 -04:00
Oleg Zhurakousky
dd52482a9b GH-2374 minor adjustments to functional error handling 2022-06-13 19:35:39 +02:00
Chris Bono
569ab2c5c5 Migrate kafka-streams-interactive-query-basic sample app 2022-06-13 11:54:55 -04:00
Chris Bono
be6db877da Migrates KafkaStreams branching sample (#2427) 
* Migrate Kafka Streams branching sample

* Cleanup some Kafka samples

* copyright header added to several files
* Spring Boot Maven plugin put into parent samples pom.xml

* Removed unused dependency and fixed title in README.adoc
 2022-06-13 11:49:15 -04:00
Rachana Devi
729aa2517a Fix typo for kafka-streams documentation 2022-06-13 11:18:49 -04:00
Oleg Zhurakousky
5a007a3833 GH-2347 Fix explicit binding creation when single function is present 
Resolves #2347
 2022-06-10 18:50:22 +02:00
Oleg Zhurakousky
0071c8e802 GH-2413 Add missing exception to ApplicationJsonMessageMarshallingConverter 
Resolves #2413
 2022-06-09 17:58:00 +02:00
Oleg Zhurakousky
723eadb67f GH-2355 Add tests for KafkaNull batching suport 
This commit also has some checksyle fixes due to s-c-build changes
Inspired by suggestion from https://github.com/spring-cloud/spring-cloud-stream/pull/2422 by @sbernardo

Resolves #2355
 2022-06-08 20:06:48 +02:00
Soby Chacko
806a6500b5 Kafka Streams binder message conversion changes 
Fixing boolean logic around non-native message conversion in Kafka Streams binder.
 2022-06-07 17:50:36 -04:00
Oleg Zhurakousky
cc28eb7c6b polishing previous commit 
Resolves #2416
 2022-06-07 15:09:25 +02:00
Sean Doyle
862b2003ab StreamBridge resolveDestination considers binderName in cache hit 2022-06-07 15:01:28 +02:00
Soby Chacko
6dd6774280 Producer config customization and DLQ issues 
When DLQ is enabled on a consumer binding, the internal producer properties
used by the DLQ mechanism to send to the topic is not populated with the
correct binding name. In the previous version, it was working fine since
we were relying on a ThreadLocal. This is revamped recently to properly
introduce a binding name as a top level property in ProducerProperties.
However, this was not set on the internal producer properties used by the
DLQ. This PR addresses this issue.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2417
Resolves #2418
 2022-06-07 14:29:46 +02:00
Oleg Zhurakousky
cc19c9f31c Fix ErrorBindingTests 2022-06-07 13:17:34 +02:00
Oleg Zhurakousky
1e141336a8 Fix ErrorBindingTests 2022-06-07 12:23:49 +02:00
Soby Chacko
ce6a03ee59 Kafk Streams binder message conversion issues 
When native decoding is disabled and message conversion
is used  in Kafka Streams binder, it doesn't currently
carry the original headers forward. Fixing this issue.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2411
 2022-06-06 19:19:14 -04:00
ferblaca
ae0332b7d4 add the topic name information to the binder exception if a problem occurs in the provisioning phase 2022-06-06 10:46:03 -04:00
Oleg Zhurakousky
cf0dd1bfa3 GH-2374 Add initial support for function-based error handling 
Resolves #2374
 2022-06-02 15:04:20 +02:00