When using the Kafka Reactive Binder to consume messages from two different Kafka Cluster the app start fails with onfigReactiveWebServerApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context
so that the configuration works but then the reactive part is ignored and it seems that the messages are consumed on a non reactive thread container-0-C-1 instead of nc-read-local-1 .
Reactive Kafka binder does not have support for multi binders (or at least we haven't tested this yet). We can add this as an enhancement item for the next release. If you are up to it, we welcome any PR contributions.
When using the Kafka Reactive Binder to consume messages from two different Kafka Cluster the app start fails with
onfigReactiveWebServerApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context
I have a similar setup like the following:
and
I tried to add the dependency:
so that the configuration works but then the reactive part is ignored and it seems that the messages are consumed on a non reactive thread
container-0-C-1
instead ofnc-read-local-1
.