spring-cloud-stream

spring-cloud-stream copied to clipboard

Hello, I am using Spring cloud stream kafka binder in my project( ver 3.1.4) I use StreamBridge for sending messages to multiple binding names. Some got partition key expression, others...

parkhaianh

**Describe the issue** Headers removed within a `Function` are re-added to the output message by `SimpleFunctionRegistry#enrichInvocationResultIfNecessary()`. **To Reproduce** Steps to reproduce the behavior: 1. Go to https://github.com/spring-cloud/spring-cloud-stream-samples/tree/main/processor-samples/uppercase-transformer 2. Upgrade `spring-boot-starter-parent`...

Nephery

New breaking changes have been added to SF6 snapshot which will require our binder child context initializer code to be slightly modified. - If you use AotFactoriesLoader you'll need to...

onobc

**Describe the issue** `@PollableBean` doesn't support Kotlin lambda while other spring-cloud-function features support it. **To Reproduce** ✅ `@PollableBean` in the following code works as intended. ```kotlin @SpringBootApplication class StreamApplication {...

asinbow

Error channel naming enhancement

1

Please add support for something like a binding name alias so that different destinations can be used but they can always be set to the same error channel bean name....

kabennett

**Describe the issue** When not using a specific `PartitionSelectorExpression` to explicitly determine the partition strategy that should be used, the `org.springframework.cloud.stream.binder.PartitionHandler.DefaultPartitionSelector` is used which essentially performs `hashCode() % numPartitions` to...

filpano

PartitionAwareFunctionWrapper can't work in concurrency >1

5

Spring Boot 2.6.6 and Spring Cloud 2021.0.1 sending a partitioned message with a function input=message output=message there are some messages miss the partition assignment as other threads may set the...

nicolas-zheng

spring function don't work fine with spring integration

2

**spring function don't work fine with spring integration** In my case.I am use spring cloud stream , then I am try to use spring integration with java dsl.First time，I use...

Xtreme-Light

Consider adding Reactor Kafka binder sample app

1

@onobc @olegz @sobychacko I think it would be useful to add sample project, and to clarify how to acknowledge manually. Also - document error handling with DLQ. _Originally posted by...

onobc

- Add doc describing how AOT works w/ the binder child context - Update AOT related class javadocs appropriately - Add tests covering this functionality

onobc