markus herbert

Results 21 comments of markus herbert

I wonder why there is a use of `DefaultKafkaConsumerFactory` and not `KafkaRecevier` & `ReceiverOptions` (also `SenderOptions` and stuff). How is this [test](https://github.com/spring-cloud/spring-cloud-stream/blob/f3ccc7b72de7e7aa5279528b3be4a990225b1100/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderIntegrationTests.java) shows the usage of SCSt with Reactor Kafka?...

@sobychacko I was struggling with trying this feature. What's the artifact's name? Can you attach a simple stupid sample (a nice addition to the `samples` dir would be awesome)

Support. I also agree with @artembilan about the fact that both the reactive and non-reactive channel adapters can be the same channel adapter, but I do understand why you suggest...

@artembilan I don't exactly agree about the java doc since this is a thing that people should infer from the reference, because this is the place where people start to...

Agree with @artembilan. This can be renamed to Protobuf & grpc support / we should add another grpc focused ticket. Grpc support is super important either.

@artembilan I think [this issue talks about a correct point.](https://stackoverflow.com/questions/71800414/how-to-handle-reactive-types-within-reactive-spring-integration). You currently can not access a flux and end the flow through it by yourself. This is really a blocker...

In general, @artembilan, is it currently possible to subscribe manually? I think a built-in feature for this can provide a lot of flexibility to the reactive spring integration users

@maciejwalkowiak any updates on this?

I think it would also be nice if there would be support for Spring Integration with Project Reactor. Something like `ReactiveS3MessageHandler`