SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
4,279 Commits 28 Branches 0 Tags
main
Commit Graph

77 Commits

Author SHA1 Message Date
Soby Chacko
e5d0d14836 Remove reactive-kafka binder 
Since the reactor-kafka project has been discontined, we are removing
reactive Kafka binder from Spring Cloud Stream which was already
deprecated on the 4.3.x line.

See: https://spring.io/blog/2025/05/20/reactor-kafka-discontinued

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-06-12 11:33:06 -04:00
Soby Chacko
5425cdd270 Deprecate Reactive Kafka Binder in 4.3.0 
See details here: https://spring.io/blog/2025/05/20/reactor-kafka-discontinued

Reactive Kafka binder will be compleltely removed in a future release

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-05-23 19:40:01 -04:00
Oleg Zhurakousky
f919d266d8 GH-3039 Update documentation to explaine usage of Spring/Boot core propertyannotations 
Resolves #3039
 2025-05-06 17:07:34 +02:00
Oleg Zhurakousky
4786fd4405 Fix docs 2025-04-28 19:09:00 +02:00
Oleg Zhurakousky
d4859e5794 GH-3106 Add documentation describing why StreamBridge does not cache bindings 
Resolves #3106
 2025-04-28 15:20:31 +02:00
Oleg Zhurakousky
ff98fb9e44 Polish previosu commit 2025-04-28 14:06:05 +02:00
Oleg Zhurakousky
165643cd6e GH-3109 Add documentation to explain explicit binding naming convention 
Resolves #3109
 2025-04-28 14:02:22 +02:00
Nayan Hajratwala
3c5113f3da Fix documentation typos 
Signed-off-by: Nayan Hajratwala <nayan@chikli.com>

Resolves #3110
 2025-04-28 12:55:54 +02:00
Nayan Hajratwala
96eb4eed3f fix typo 
Signed-off-by: Nayan Hajratwala <nayan@chikli.com>
 2025-04-28 12:55:40 +02:00
Oleg Zhurakousky
52913cef03 GH-3108 Fix links in docs 
Resolves #3108
 2025-04-22 15:11:53 +02:00
Oleg Zhurakousky
27c68b267b GH-3086 Fix naming for explicit bindings that are not backed by a function 2025-04-15 15:04:56 +02:00
Oleg Zhurakousky
143ac8208a GH-3086 Add documentation for defining new bindings 
Add documentation for defining new bindings via BindingsLifecycleController

Resolves #3086
 2025-04-14 09:19:42 +02:00
William Walters (He/Him)
8990e7e4b9 Fix typo in record-serialization-and-deserialization doc 
Should be `useNativeEncoding`, not `nativeEncoding`: https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_producer_properties

Signed-off-by: William Walters (He/Him) <william.h.walters12@gmail.com>
 2025-03-11 15:58:45 -05:00
Soby Chacko
b342c2157f Document exception retry behavior for Kafka transactions 
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-10 17:11:16 -04:00
F. Emerson
fe6a0ab8b7 Fix typos in documentation 
Signed-off-by: F. Emerson <t@utologi.cc>
 2025-01-30 18:21:41 -03:00
Oleg Zhurakousky
b5b8b3089d GH-3071 Add documentation for accessing producer/consumer properties 
Resolves #3071
 2025-01-30 15:35:33 +01:00
Destan Sarpkaya
9b1fbfb59d Clarify that having a custom error handler disables auto send to DLQ 2025-01-03 16:40:39 +03:00
Oleg Zhurakousky
f392488dae Merge pull request #3044 from omercelikceng/fix-typo-docs 
Fix typo in docs for rabbit and spring cloud stream sections
 2024-12-04 13:12:26 +01:00
Ömer Çelik
94f061d4cc Fix typo in docs for rabbit and spring cloud stream sections 2024-11-18 18:14:27 +03:00
Ömer Çelik
7c396a602c Fix typo in docs 2024-11-18 18:05:47 +03:00
Oleg Zhurakousky
a67de87e42 Merge pull request #3029 from beni0888/fix-typo-overview-error-handling 
Fix typo in overview-error-handling.adoc
 2024-11-18 14:09:43 +01:00
Jesús Miguel Benito Calzada
84e7238922 Fix typo in overview-error-handling.adoc 2024-11-06 10:28:12 +01:00
aviv-amdocs
01a508187c Update timeout default 2024-10-30 15:01:00 +02:00
Glenn Renfro
efbe2cd005 Update docs to show correct prefix for connection-name-prefix 
Currently docs display the correct prefix as spring.cloud.stream.binder where it should be spring.cloud.stream.rabbit.binder
 2024-10-21 10:06:50 -04:00
Artem Bilan
c96a62f163 GH-2939: Rely on custom AmqpHeaders.RETRY_COUNT for server retries 
Fixes: https://github.com/spring-cloud/spring-cloud-stream/issues/2939

The RabbitMQ 4.0 does not deal with client side `x-*` headers.
Therefore, an `x-death.count` is not incremented anymore when
message is re-published from client back to the broker.

* Spring AMQP 3.2 has introduced an `AmqpHeaders.RETRY_COUNT` custom header.
Use `messageProperties.incrementRetryCount()` in the `RabbitMessageChannelBinder`
when we re-published message back to the broker for server-side retries
* Fix docs respectively

Resolves #3019
 2024-10-17 12:00:11 +02:00
Oleg Zhurakousky
eea905f692 Merge pull request #3015 from sobychacko/gh-2985 
GH-2985: Add Kafka Listener Container Customizer interfaces and docum…
 2024-10-07 18:43:26 +02:00
Oleg Zhurakousky
7a5e5d0541 Fix broken cross reference links 
Resolves #3018
 2024-10-07 18:07:44 +02:00
Soby Chacko
f8d6caa429 GH-2985: Add Kafka Listener Container Customizer interfaces and documentation 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2985

This commit introduces new customization options for Kafka listener containers
in Spring Cloud Stream, along with comprehensive documentation:

- Add KafkaListenerContainerCustomizer interface for Kafka-specific customization
  with access to extended consumer properties
- Extend ListenerContainerWithDlqAndRetryCustomizer to include access to
  extended consumer properties
- Update KafkaMessageChannelBinder to support the new customizer interfaces
- Implement KafkaListenerContainerCustomizerTests for integration testing
- Add detailed AsciiDoc reference documentation explaining the purpose,
  usage, and hierarchy of these customizer interfaces:
  * ListenerContainerCustomizer (existing)
  * KafkaListenerContainerCustomizer (new)
  * ListenerContainerWithDlqAndRetryCustomizer (extended)
- Update navigation to include the new documentation

These changes enhance the flexibility and configurability of Kafka consumer
endpoints in Spring Cloud Stream applications, allowing users to fine-tune
their listener containers based on specific requirements and scenarios,
with improved access to Kafka-specific properties.
 2024-10-04 17:53:13 -04:00
Oleg Zhurakousky
5d881b2adb GH-2994, GH-2986 Add documentation explaining batch type conversion 2024-09-23 16:47:36 +02:00
Soby Chacko
42d91e0ff3 GH-2650: Observability enhancements in reactive Kafka binder 
Fixes https://github.com/spring-cloud/spring-cloud-stream/issues/2650

* Enable native observability support for output binding in the reactive Kafka binder
* Adding test to verify this support with downstream consumers
* Adding ref docs
* Addressing PR review
 2024-09-19 12:48:19 -04:00
andq
1b4e3fbad8 Fix typo in docs 2024-08-03 19:41:18 +02:00
Chanhyeong Cho
ae32191310 Minor cleanup 
* Remove reference to @EnableBinding in DefaultBinding
* Docs cleanup
 2024-06-17 15:20:50 -04:00
Soby Chacko
a3c4364740 GH-2949: KafkaBinderHealthIndicator consumer group.id 
* Add a new property in `KafkaBinderConfigurationProperties` to allow
  the users to specify a `group.id` for the metadata consumer used by the
  health indicator.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2949
 2024-05-13 20:43:30 -04:00
Soby Chacko
7e20c9efbe Adding docs for ReactorKafkaBinderHealthIndicator 
See https://github.com/spring-cloud/spring-cloud-stream/issues/2948
 2024-05-13 16:08:11 -04:00
kutmk
1f41055917 Add @EnableTestBinder annotation (#2947) 
* Add @EnableTestBinder annotation
* Use @EnableTestBinder in tests
* Update copyright and author tag
* Add javadoc
* Update explanation to use @EnableTestBinder

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2931
 2024-05-13 11:29:00 -04:00
Soby Chacko
9cbd45910e GH-2926: Clarify docs on observablity when consuming in batches 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2926

* Clarify docs on Observability when consuming records in batch mode in Kafka binder
 2024-04-29 18:33:07 -04:00
Soby Chacko
7845be50ef GH-2932: Sanitize sensitive data on bindings endpoint 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2932

Spring Boot provides `SanitizingFunction` to allow the applicaitons to clear out
sensitive data when using certain actuator endpoints. This feature can be
extended to custom endpoints as well. Enable the bindings actuator endpoint
to sanitze sensitive data based on user-provided logic in `SantizingFuction`
beans in the application.
 2024-04-17 17:30:28 -04:00
Soby Chacko
a636eec47c GH-2933: Clarify docs on adding global state stores 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2933
 2024-04-09 14:44:45 -04:00
lazare
5a231df52d fixed typo in configuration-options.adoc 2024-03-25 17:52:10 -04:00
Soby Chacko
568c82d889 Fixing typo - consuming batch docs 2024-03-21 16:22:18 -04:00
Soby Chacko
a2458f3029 Clarify batch-consuming docs for Kafka binder 
Based on this issue: https://github.com/spring-cloud/spring-cloud-stream/issues/2917
 2024-03-14 10:54:52 -04:00
Soby Chacko
fac0c143ad GH-2560: Clarify docs on error handling/DLQ 
* Clarify the docs on retry behavior in Kafka binder when max-attempts set to 1 and no DLQ

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2560
 2024-03-08 18:20:43 -05:00
Soby Chacko
b08fe14dd7 Move core error handling docs to top-level 
Kafka binder error channels docs cleanup
 2024-03-08 17:40:12 -05:00
Soby Chacko
05b1eadd78 Docs cleanup 2024-03-08 15:59:56 -05:00
Soby Chacko
b595302f9c Cleanup default properties docs 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2906
 2024-03-08 15:51:00 -05:00
Soby Chacko
5f1611a4aa GH-2884: Docs on Pulsar Binder Config Props 
Adding a brief docs section for the Pulsar binder config properties.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2884
 2024-03-01 17:19:05 -05:00
Oleg Zhurakousky
7fa72282c1 GH-2898 Add support for asyn send to StreamBridge 2024-02-14 21:17:27 +01:00
Soby Chacko
977b5e3a4c Cleaning up Kafka Streams binder antora docs 2024-02-13 15:10:04 -05:00
Soby Chacko
b26c21aacf Fixing Kafka binder docs navigation 2024-02-01 18:49:13 -05:00
Soby Chacko
aea0e8f591 Kafka binder docs cleanup 
Fixing a few broken links in config options docs
 2024-01-26 15:59:25 -05:00