You can continue to use spring Kafka blocking library and convert messages to Mono and Flux. Since kafka’s Java client is intrinsically blocking at its core
o
Oğuzhan Soykan
12/15/2025, 2:01 PM
Makes sense. Do you still think about rebalancing, consumer drop, error handling, or you let spring-kafka handle those things and focus on flux/flow creation?
p
Pedro Marques
12/15/2025, 2:04 PM
Yes, you should deliberately let Spring Kafka handle rebalancing, consumer drop, retries, commits, etc., and you focus on building the Flux / processing flow.