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

90 Commits

Author SHA1 Message Date
buildmaster
ebe26904a5 Bumping versions to 3.2.11-SNAPSHOT after release 2023-12-18 22:59:44 +00:00
buildmaster
c4d30d1fd4 Going back to snapshots 2023-12-18 22:59:43 +00:00
buildmaster
1e83dd8c1f Update SNAPSHOT to 3.2.10 2023-12-18 22:55:52 +00:00
Soby Chacko
ca2b5e5c00 Test cleanup, checkstyle fixes 2023-10-30 16:12:03 -04:00
Fernando Blanch
9c9da804e2 Support pause/resume for consumer bindings with multiple destinations from BindingsLifecycleController 
add test queryng a binding that not exists return empty list

remove unnecessary formatting changes

Resolves #2660
Resolves #2658
 2023-10-30 14:54:07 -04:00
Oleg Zhurakousky
8059cdabcf Fix property value type 2023-09-26 07:11:05 +02:00
buildmaster
353409ac2a Bumping versions 2023-06-30 13:40:17 +00:00
buildmaster
deb2bdd053 Bumping versions 2023-06-29 13:43:21 +00:00
buildmaster
827f052b29 Bumping versions to 3.2.10-SNAPSHOT after release 2023-06-29 11:09:09 +00:00
buildmaster
414115ed45 Going back to snapshots 2023-06-29 11:09:08 +00:00
buildmaster
af7ff9bf79 Update SNAPSHOT to 3.2.9 2023-06-29 11:05:50 +00:00
buildmaster
29e6c03e83 Bumping versions to 3.2.9-SNAPSHOT after release 2023-04-27 14:51:12 +00:00
buildmaster
4c1882ee5c Going back to snapshots 2023-04-27 14:51:11 +00:00
buildmaster
c7be174289 Update SNAPSHOT to 3.2.8 2023-04-27 14:47:37 +00:00
조찬형[Plasma]
6c193d6b37 Replace duplicate code with existing method 
Resolves #2702
 2023-04-11 14:37:29 +02: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
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
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
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
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
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
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
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
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
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
Gary Russell
37126f566f 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:49:20 +02:00
buildmaster
08fccf3fc3 Bumping versions 2022-08-16 13:45:50 +00:00
Chris Bono
17145dcc27 Make InteractiveQueryService only return used state stores (backport #2445) 
This restores to KafkaStreams 3.0 behavior in this area.
 2022-06-28 09:39:43 -04:00
Pommerening, Nico
b105d8a2e9 Kafka Streams binder health indicator improvements 
Fix KafkaStreamsBinderHealthIndicator overriding HealthCheck Thread Details to report full details.

checkstyle fixes.
 2022-06-23 14:30:17 -04:00
buildmaster
4e86710685 Bumping versions 2022-06-23 13:45:06 +00:00
Chris Bono
8a1aee4655 Fix and improve SerdeResolverUtilsTests (#2444) 
* Simplify SerdeResolverUtilsTests setting of ineligible-definitions

* Improve KafkaStreams ineligible-definitions property handling

* KafkaStreamsBinderEnvironmentPostProcessor respects existing ineligible-definitions
* Add tests for KafkaStreamsBinderEnvironmentPostProcessor

* Fix SerdeResolverUtilsTests failure
 2022-06-22 17:05:45 -04:00
yiliu6
c5506ba194 Enable multiple AdminClientConfigCustomizer 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2423
 2022-06-22 15:04:59 -04:00