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

380 Commits

Author SHA1 Message Date
sy.choi
39eca198fb add word spacing 2023-07-06 12:42:13 -04:00
Gary Russell
38503aa34f GH-2673: Fix Doc Anchor Name 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2763
 2023-06-29 11:46:05 -04:00
Chanhyeong Cho
33528d1114 Polish documentations 2023-05-31 10:00:51 -04:00
buildmaster
0b7d773b30 Bumping versions to 4.0.4-SNAPSHOT after release 2023-05-24 18:47:37 +00:00
buildmaster
16cf46d74f Going back to snapshots 2023-05-24 18:47:37 +00:00
buildmaster
1550366414 Update SNAPSHOT to 4.0.3 2023-05-24 18:43:23 +00:00
Gary Russell
ac6dd61630 GH-2729: Reactor Kafka Binder SenderResult Support (#2730) 
* GH-2729: Reactor Kafka Binder SenderResult Support

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

Allow configuration of a `FluxMessageChannel` to receive `SenderResult`s.
Add `SenderResultMessageHandler` to consume from that channel.

Remove undocumented `sendResult` header, which has no value without the
sender result correlation metadata.

* Add integration test and polish property docs.

- result channel must be FMC for reactive binder.

* Add documentation.

* Remove SenderResultMessageHandler.
 2023-05-17 16:10:20 -04:00
Soby Chacko
4d65ccd235 Kafka binder partitioning doc improvements (#2735) 
* Kafka binder partitioning doc improvements

* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc

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

* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc

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

* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc

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

---------

Co-authored-by: Gary Russell <grussell@vmware.com>
 2023-05-15 16:48:25 -04:00
oliverfuehrer
29c3cd7cdd Dynamic partition improvements in Kafka binder 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2706

  - Update partition count changes in Kafka dynamically during runtime
  - Checkstyle fixes
  - PartitionHandler changes
  - Improved handling of expression with 'payload' in the logic
  - Removed getter/setter for PartitionHandler and use ReflectionUtils within Test
  - Renamed property to 'dynamicPartitionUpdatesEnabled' and improved documentation (also one line per sentence)
  - Improved/renamed test to use embeddedkafka and really test update behaviour
  - Javadoc
 2023-05-09 10:14:12 -04:00
Jay Kim
a5f9380a55 Correct configuration path for AckMode in the kafka tips document 2023-04-25 09:53:09 -04:00
Gary Russell
9a67030d90 GH-2709: Reactive Kafka Binder Pattern Docs 2023-04-18 14:17:20 -04:00
Marc DiPasquale
eb2de7bd42 Add Solace updates 2023-04-18 18:34:11 +02:00
Soby Chacko
6aaad6f619 Clarify docs for binding keys with special chars 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2699
 2023-04-18 18:33:37 +02:00
Soby Chacko
f78d410ff6 Enhancing docs on the usage of test binder 
- Docs on mixing test binder and the actual middleware based binder.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2684
 2023-04-18 18:33:05 +02:00
Oleg Zhurakousky
0b5ae251f9 GH-2707 Add PostProcessing documentation 
Resolves #2707
 2023-04-14 17:23:29 +02:00
Soby Chacko
dd8e707e01 Update Kafka Streams binder docs 
spring.cloud.stream.function.definition -> spring.cloud.function.definition.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2680
 2023-04-05 16:48:35 -04:00
Gary Russell
f48523f774 GH-2691: Kafka Reactive Binder Support Multiplex (#2698) 
* GH-2691: Kafka Reactive Binder Support Multiplex

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

* Add docs.
 2023-04-05 15:50:07 -04:00
Gary Russell
92279db2a1 GH-2686: Reactive Kafka Fix Auto Commit 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2686

Due to `.concatMap()`, offsets were committed before passing the records to
the pipeline.
 2023-04-05 15:46:54 -04:00
Ilya Serbis
4b7ced0062 Update documentation 
fix code and bring it in line with the codebase
 2023-04-05 10:29:08 -04:00
buildmaster
ea37eed9be Bumping versions 2023-03-29 17:33:29 +00:00
buildmaster
b2f2b51b90 Bumping versions 2023-03-28 17:27:48 +00:00
buildmaster
58c028f339 Bumping versions to 4.0.3-SNAPSHOT after release 2023-03-28 14:51:23 +00:00
buildmaster
c45f2e3ac7 Going back to snapshots 2023-03-28 14:51:22 +00:00
buildmaster
d932cf990f Update SNAPSHOT to 4.0.2 2023-03-28 14:47:17 +00:00
Oleg Zhurakousky
4936cba75b GH-2663 Remove references to deprecated property 
Resolves #2663
 2023-03-28 08:59:11 +02:00
buildmaster
8e73b291f0 Bumping versions 2023-03-21 17:26:44 +00:00
Steven PG
e5d4916a4d Stream batch produce consume (#2654) 
Kafka Binder-based Batch Producer and Consumer

 - Provide a new sample for batch producer and consumer with the Kafka binder
 2023-03-09 20:15:53 -05:00
Oleg Zhurakousky
fba22efcb2 Remove notable deprecations section 2023-03-01 13:56:06 +01:00
Oleg Zhurakousky
dfcda941aa Fix MessageConverter list in the docs 
Resolves #2659
 2023-03-01 13:43:15 +01:00
Soby Chacko
986b54f5d0 Schema Registry Testing Improvements 
- Allow Schema Registry to be optional when
   running unit tests.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2641
 2023-02-24 17:03:49 -05:00
Gary Russell
82aa2cf41a GH-2653: Reactor Kafka Binder Fix Offset Commits 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2653

Add support for auto and manual offset commits.
Resolves #2656
 2023-02-23 15:24:37 +01:00
Soby Chacko
371815806b 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>
 2023-02-13 12:05:28 -05:00
Gary Russell
a325b8b9fd GH-2634: Reactor Kafka Binder Customization 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2634

Allow customization of `ReceiverOptions` and `ProducerOptions`.
 2023-01-27 09:51:03 -05:00
Byungjun You
7895025c47 Use 'instanceof' pattern variable 
Update authors and copyright years

Fixing checkstyle issue
 2023-01-26 11:30:04 -05:00
buildmaster
b49fde97c8 Bumping versions 2023-01-26 16:01:13 +00:00
buildmaster
7bff24af68 Bumping versions 2023-01-25 17:26:18 +00:00
buildmaster
46bc9c5709 Bumping versions to 4.0.2-SNAPSHOT after release 2023-01-25 14:33:14 +00:00
buildmaster
8c413de78c Going back to snapshots 2023-01-25 14:33:13 +00:00
buildmaster
656469da4f Update SNAPSHOT to 4.0.1 2023-01-25 14:28:45 +00:00
Soby Chacko
0612ea85f7 Event type routing and deserialization issues (#2633) 
* Event type routing and deserialization issues

In Kafka Streams binder, deserialization exception handler
does not take effect when event type routing is enabled.
Fixing this issue by allowing the applications to use the
configured or inferred Serde rather than the byte[] Serde
used by the event type router initially.

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

* Addressing PR review
 2023-01-24 21:49:45 -05:00
Byungjun You
82a863d0f0 Remove the gitter chat badge in the README 2023-01-23 15:18:03 +01:00
Oleg Zhurakousky
446d066c1d GH-2626 Fix documentation related to explicit binding name change 2023-01-19 15:44:15 +01:00
Byungjun You
02241661a5 fix @return tag comment for retryAndDlqInBinding 2023-01-19 14:00:05 +01:00
Byungjun You
130a295d04 fix the default DLT name in kafka_tips.adoc 2023-01-11 12:08:44 -05:00
Soby Chacko
8b0fbe122f Allow fine tuning of StoreQueryParameters (#2618) 
Add StoreQueryParametersCustomizer to InteractiveQueryService 
in Kafka Streams binder.

Fixes #2608
 2023-01-10 18:11:09 -06:00
Byungjun You
a8114cee9a Fix typos in kafka_tips.adoc 2023-01-10 11:24:07 -05:00
Soby Chacko
8fb166fc58 Fix test binder docs 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2598
 2023-01-04 16:57:45 +01:00
Filip Panovski
9e31e2eae1 Extend docs on default partitioning strategy in Kafka binder 
- Resolves GH-2467
 2023-01-03 15:50:11 -05:00
buildmaster
d40e733221 Bumping versions 2022-12-18 17:27:01 +00:00
buildmaster
f1d4f8a53e Bumping versions 2022-12-16 17:26:47 +00:00