FITFLOP
Home

project-reactor (11 post)


posts by category not found!

Kafka-reactor to read the same kafka message again if message processing failed

Handling Failed Message Processing with Kafka Reactor In modern microservices architecture message brokers like Apache Kafka play a pivotal role in facilitating

3 min read 16-10-2024 31
Kafka-reactor to read the same kafka message again if message processing failed
Kafka-reactor to read the same kafka message again if message processing failed

Webclient timeout exception while sending high traffic

Web Client Timeout Exceptions Battling High Traffic with Grace Imagine this your web application is humming along handling user requests with ease Suddenly a su

3 min read 05-10-2024 26
Webclient timeout exception while sending high traffic
Webclient timeout exception while sending high traffic

Reactor kafka: Consume messages, save to database and after insertion perform another action

Reactor Kafka Consuming Messages Saving to Database and Performing Subsequent Actions Imagine a scenario where you need to consume messages from a Kafka topic p

2 min read 05-10-2024 24
Reactor kafka: Consume messages, save to database and after insertion perform another action
Reactor kafka: Consume messages, save to database and after insertion perform another action

Listening to another topic using KafkaReciver after initializing it

Switching Topics with Kafka Receiver Dynamic Consumption in Apache Kafka Imagine you have a Kafka Receiver set up to listen to a specific topic Your application

3 min read 03-10-2024 27
Listening to another topic using KafkaReciver after initializing it
Listening to another topic using KafkaReciver after initializing it

Delay elements on particular GroupedFlux among others

Delaying Elements in a Grouped Flux A Guide to Controlled Data Flow Lets say you re working with a reactive stream of data that needs to be processed in groups

2 min read 02-10-2024 27
Delay elements on particular GroupedFlux among others
Delay elements on particular GroupedFlux among others

How to get inputStream as return value from ServerHttpRequest in spring reactive?

How to Access the Request Body as an Input Stream in Spring Reactive When working with Spring Reactive applications you might encounter scenarios where you need

3 min read 02-10-2024 32
How to get inputStream as return value from ServerHttpRequest in spring reactive?
How to get inputStream as return value from ServerHttpRequest in spring reactive?

Kotlin Type Mismatch on Subclass with Monos

Kotlin Type Mismatch Subclass and Monos Explained Lets say you re working on a Kotlin project and encounter this error message kotlin Type mismatch inferred typ

2 min read 02-10-2024 24
Kotlin Type Mismatch on Subclass with Monos
Kotlin Type Mismatch on Subclass with Monos

Connection Closed BEFORE Send Operation After Upgrading Spring Boot to 3.2.4

Spring Boot 3 2 4 Connection Closed Before Send Operation Troubleshooting Guide Upgrading your Spring Boot application to version 3 2 4 can be a great step forw

3 min read 01-10-2024 32
Connection Closed BEFORE Send Operation After Upgrading Spring Boot to 3.2.4
Connection Closed BEFORE Send Operation After Upgrading Spring Boot to 3.2.4

Using StepVerifier.withVirtualTime for a WebClient request using exponential backoff/fixedDelay does not work

Step Verifier with Virtual Time and Web Client A Tale of Exponential Backoff and Fixed Delay Lets dive into a common scenario encountered when testing asynchron

4 min read 01-10-2024 26
Using StepVerifier.withVirtualTime for a WebClient request using exponential backoff/fixedDelay does not work
Using StepVerifier.withVirtualTime for a WebClient request using exponential backoff/fixedDelay does not work

Is it possible to run reactive mongo driver without Spring boot and Spring data?

Running Reactive Mongo Driver Without Spring Boot and Spring Data Is It Possible When developing applications that require non blocking database access many dev

3 min read 01-10-2024 24
Is it possible to run reactive mongo driver without Spring boot and Spring data?
Is it possible to run reactive mongo driver without Spring boot and Spring data?

How to store a Mono error in Async Caffeine Cache?

How to Store a Mono Error in Async Caffeine Cache When working with asynchronous programming in Java particularly with the Project Reactor library managing erro

3 min read 29-09-2024 30
How to store a Mono error in Async Caffeine Cache?
How to store a Mono error in Async Caffeine Cache?