python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - reactor-kafka

Can Spring Integration cause a Reactive Application to block?

I’m using Project Reactor for a non-blocking IO data pipeline, and I’m thinking of using Spring Integration as an abstraction layer to manage all of the flows and components in my pipeline. I’m curren...
test-img

user7551211

spring

spring-boot

spring-integration

project-reactor

reactor-kafka

Votes: 0

Answers: 1

Latest Answer

In most cases Spring Integration components are stateless, so they are safe to use in multi-threaded (or non-blocking) environment. You may suffer some concerns if you use a specific channel adapter w...
test-img

Artem Bilan

"Found ambiguous parameter type Void"? Spring Integration with Project Reactor

I'm using Project Reactor with Spring Integration to read from Kafka and write to MongoDB, and I the Kafka consume works well, but the .handle(MongoDb.reactiveOutboundChannelAdapter(mongoFactory)) stu...
test-img

user17954501

spring

spring-integration

project-reactor

reactor-kafka

spring-data-mongodb-reactive

Votes: 0

Answers: 2

Latest Answer

You cannot do new ReactiveMongoDbStoringMessageHandler(mongoFactory) if you are not going to subscribe to the returned Mono. A .handle(MongoDb.reactiveOutboundChannelAdapter(mongoFactory)) is the rig...
test-img

Artem Bilan

Posts

Questions

Blogs

Jobs