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

3476 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko
e407a9cf80 Clarify docs for binding keys with special chars 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2699
 2023-04-19 11:05:09 -04:00
조찬형[Plasma]
6c193d6b37 Replace duplicate code with existing method 
Resolves #2702
 2023-04-11 14:37:29 +02:00
Oleg Zhurakousky
86df59777b Add getBindingServiceProperties method to AbstractMessageChannelBinder 2023-03-27 09:39:03 +02:00
Oleg Zhurakousky
4b09e921ca GH-2664 Add support for displaying binder name/type 
Resolves #2664

GH-2664 polishing
 2023-03-27 09:12:58 +02:00
Oleg Zhurakousky
691dc1d3d9 Fix MessageConverter list in the docs 
Resolves #2659
 2023-03-01 13:44:20 +01:00
buildmaster
80adb4ea06 Bumping versions 2023-02-24 20:08:13 +00:00
buildmaster
09c1e00df6 Bumping versions to 3.2.8-SNAPSHOT after release 2023-02-23 22:49:38 +00:00
buildmaster
431fefa6a8 Going back to snapshots 2023-02-23 22:49:38 +00:00
buildmaster
76e84cb49c Update SNAPSHOT to 3.2.7 2023-02-23 22:46:31 +00:00
Simas Joneliunas
1ee96ab788 Update README.adoc 
Fix typo in readme

Resolves #2657
 2023-02-23 15:27:10 +01:00
spencergibb
ca14b3542e Removes use of List.of() not available in java 8 2023-02-22 12:33:50 -05:00
Soby Chacko
13bb288499 Supporting DLQ in batch mode (#2649) 
* Supporting DLQ in batch mode

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

* PR review

Co-authored-by: Gary Russell <grussell@vmware.com>

---------

Co-authored-by: Gary Russell <grussell@vmware.com>

Polish to previous commit
 2023-02-13 15:37:46 -05:00
Oleg Zhurakousky
0c74f2f460 GH-2612 Fix initialization ordering issue with actuator endpoints 
this also includes improvement where channels are now retrieved dynamically allowing new channels created during the runtime of the application to be visible as well
Resolves #2612
 2023-01-19 15:15:09 +01:00
Oleg Zhurakousky
24c89a5d01 GH-2262 Ensure BindingHandlerAdvise is propagated to binder context 
During multiple binder scenarious BindingHandlerAdvise must be propagated to binder context to ensure that default properties are properly bound

Resolves #2262
 2023-01-12 19:02:25 +01:00
Oleg Zhurakousky
7b4a85a5b7 GH-2590 Fix logic to determine if function is a RoutingFunction 2023-01-06 13:57:59 +01:00
Soby Chacko
b2199ca217 Test deps cleanup in Kafka Streams binder 
Remove superfluous Kafka test dependencies in Kafka Streams binder

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2573
 2022-12-05 11:48:04 -05:00
Gary Russell
ec49293c48 Fix Doc ToC (3.2.x) 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2554
 2022-11-17 09:26:06 -05:00
buildmaster
ddc6a722b3 Bumping versions to 3.2.7-SNAPSHOT after release 2022-11-03 15:06:19 +00:00
buildmaster
3b808bda8f Going back to snapshots 2022-11-03 15:06:18 +00:00
buildmaster
03690257b6 Update SNAPSHOT to 3.2.6 2022-11-03 15:03:15 +00:00
Atsushi Yoshikawa
384ba2a8f8 Fix producer Binding#companion bean not set 2022-10-31 10:24:12 +01:00
Soby Chacko
b125603266 Dependency cleanup - Kafka binder 
Revmoe unnecessary explicit depdency of kafka-clients in the binder
 2022-10-27 12:57:42 -04:00
Soby Chacko
6faa169800 Dependency cleanup in Kafka binder 
Remove unnecessary test dependencies added as
compile scope in Kafka binder.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2546
 2022-10-26 14:56:53 -04:00
Soby Chacko
d37e785a7d checkstyle fixes 2022-10-20 12:02:05 -04:00
omercelikceng
f3c82b888b KafkaTopidProvisioner retry refactoring 
Use a retry template for topic description method call through admin client
when provisioning consumer destinations. We are retrying because in the event
this operation gets failed, it is retried with the default retry settings in the provisioner.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2520
 2022-10-20 12:01:12 -04:00
Oleg Zhurakousky
fdf6d7a09a GH-2429 Add default implementation of isPaused() to Binding 
Resolves #2429
 2022-10-17 17:21:13 +02:00
Chris Bono
4fc40a04e6 GH-2523: Update topology facade to match impl in main branch 2022-10-15 10:47:44 -05:00
Chris Bono
80e300fa61 GH-2523: Smarter state store retrieval in InteractiveQueryService 
See #2523
 2022-10-14 11:30:33 -05:00
Chris Bono
faae7705c4 GH-2523: Adjust tests to surface bug during state store retrieval 
See #2523
 2022-10-14 11:30:33 -05:00
Oleg Zhurakousky
a84a42188d GH-2522 polishing previous commit 2022-10-05 17:00:59 +02:00
Oleg Zhurakousky
42a43af4c2 GH-2522 Add support for propagating select beans across child AC 
Resolves #2522
 2022-10-05 15:18:36 +02:00
Oleg Zhurakousky
6b6b8788e5 GH-2283 Fix binder specific 'default' bindings 
Resolves #2283
 2022-10-04 20:35:35 +02:00
Ginkgo
bc973e3462 Fix KafkaBinderHealthIndicator return Down Error 
When we set enable.auto.commit to true, the actuator/health returns DOWN status.

For more details see this: https://github.com/spring-cloud/spring-cloud-stream/pull/2504#issue-1361385289

Update KafkaBinderConfigurationProperties.java

Polish commit
 2022-10-03 19:32:47 -04:00
Soby Chacko
c670efdc08 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-09-28 11:40:26 -04:00
Oleg Zhurakousky
eebf6e2bd2 GH-2482 Add docs about reactive vs imperative functions 
Resolves #2482
 2022-09-28 14:21:44 +02:00
buildmaster
d51766c4a6 Going back to snapshots 2022-09-06 19:53:31 +00:00
buildmaster
2c873d9618 Update SNAPSHOT to 3.2.5 2022-09-06 19:50:30 +00:00
Nico Heller
eaee63d660 GH-2485: Improvements in Kafka Binder Metrics 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2485

These improvements are threading related

Initial implementation

Readd missing 'cache' for recent offset lags and general refactoring

Add a test case for the schedule-only variant and externalize scheduling interval

Consistency of configuration property naming and minor cleanup of existing code

Review feedback: documentation, author addition and copyright adjustments

Doc wording changes

Fix checkstyle issues

Adjust reference doc and improve new property names according to review

Move documentation to the correct file

Use JDK 8 compatible APIs and make the new test case public to satisfy junit
 2022-09-02 17:15:38 -04:00
buildmaster
1964f31cfc Bumping versions to 3.2.6-SNAPSHOT after release 2022-09-02 21:10:58 +00:00
buildmaster
4a6c6f629f Going back to snapshots 2022-09-02 21:10:57 +00:00
buildmaster
0341637fa6 Update SNAPSHOT to 3.2.5 2022-09-02 21:08:03 +00:00
Oleg Zhurakousky
bed295e66f GH-2470 Verify Kotlin lambda working with PollableBean 
Resolves #2470
 2022-08-31 15:48:16 +02:00
Oleg Zhurakousky
8b9f1349fc GH-2501 Maje StreamBridge 'safer' if created outside of Spring 
Resolves #2501
 2022-08-31 13:36:24 +02:00
Oleg Zhurakousky
3fc3097852 Small cleanup in StreamBridge 
Remove redundant injection of FunctionRegistry since it is the same as FunctionCatalog
 2022-08-29 16:51:42 +02:00
Oleg Zhurakousky
644224802b Finish JUnit5 migration 2022-08-29 15:07:22 +02:00
Chris Bono
a756bfcb3e Make KafkaStreamsBinderBootstrapTest work with Spring Boot 2.7.x 2022-08-25 14:42:09 -04:00
Chris Bono
70ab071222 Remove Kafka version mgmt from Kafka binders (#2489) 
Instead delegate all Kafka version management to the Spring Boot BOM.
 2022-08-22 21:52:58 -05:00
buildmaster
168184b370 Bumping versions 2022-08-19 13:45:02 +00:00
Chris Bono
06994b84b1 Adjust maven surefire plugin to avoid OOME in Jenkins (#2487) 2022-08-18 15:49:35 -05:00
Gary Russell
710a2b4712 GH-2483: Fix Tests 2022-08-18 10:20:51 -04:00