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

3589 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
dependabot[bot]
db8b797e11 Bump h2 from 1.4.192 to 2.1.210 in /schema-registry 
Bumps [h2](https://github.com/h2database/h2database) from 1.4.192 to 2.1.210.
- [Release notes](https://github.com/h2database/h2database/releases)
- [Commits](https://github.com/h2database/h2database/compare/version-1.4.192...version-2.1.210)

---
updated-dependencies:
- dependency-name: com.h2database:h2
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
 2022-08-26 13:58:38 -04:00
buildmaster
f4320adb95 Bumping versions 2022-08-26 17:37:59 +00:00
Oleg Zhurakousky
76d8e97614 Disabling temporary endpoint test due to boot changes 2022-08-25 19:48:08 +02:00
Soby Chacko
e1f173e139 Schema Registry Migration 
Initial attempt at migrating schema registry from https://github.com/spring-cloud/spring-cloud-schema-registry
to Spring Cloud Stream.

Schema Registry within the scope of Spring Cloud Stream will only support Spring Cloud Stream
specific use cases in the context of binders.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2491

Resolves #2492
 2022-08-25 19:47:34 +02:00
Gary Russell
0daa58c48a GH-2483: Fix Tests 2022-08-18 10:19:19 -04:00
Gary Russell
f7146ad02e GH-2483: RMQ: Fix Redeclare Multi Routing Keys 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2483

https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/242
added support for binding a queue with multiple routing keys. However, only
one binding was added to the `autoRedeclarContext`.

Use the `Declarables` wrapper to support multiple instances with the same
name.

**cherry-pick to 3.2.x**
Resolves #2484
 2022-08-18 15:47:17 +02:00
Chris Bono
71ee26b0a1 Use empty context for AOT binder child context 
Previously, when running in AOT mode the binder child context
was created w/ the same beans as when in JVM mode. The whole
point of the former is to static initialize an empty fresh context
using the AOT generated initializer.
 2022-08-17 12:59:44 -04:00
Soby Chacko
3178464f14 Fixes typo in docs. 
Resolves #2478
 2022-08-15 14:13:22 -04:00
Chris Bono
f94da9d311 Update Spring Boot from 3.0.0-M4 -> 3.0.0-SNAPSHOT 
Adapts to the following changes in upstreams libs:

- Spring Kafka removed ListenableFuture
- Spring AOT changed generator API

Fixes #2473 #2465

Checkstyle fixes
 2022-08-09 10:32:25 -04:00
Bowen Li
b33c76ad84 Update Binding.java 2022-08-08 15:42:18 +02:00
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