Можно ли настроить несколько привязок к одному процессору в Spring Cloud Stream?

Question

У меня есть простой поток Spring Integration, который связывается с процессором для ввода и вывода.

Я настроил механизм связывания Kafka для сопоставления темы ввода и вывода. Это прекрасно работает.

Скажем, я хочу связать 3 темы Kafka с входом, в результате 3 настроенных потребителя извлекают из трех отдельных тем Kafka, которые затем обрабатываются моим потоком SI.

IsМожно ли сопоставить несколько тем Kafka для ввода моего процессора? Если это так, как будет выглядеть эта конфигурация?

Answer 1

Если свойство destination является списком с разделителями-запятыми, контейнер слушателя будет создан для каждого получателя и привязан к одному и тому же слушателю.

Вы также можете установить для свойства multiplex значение true, поэтому мытолько один контейнер прослушивает несколько тем.

spring.cloud.stream.binding.foo.consumer.multiplex=true.

/**
 * When set to true, the underlying binder will natively multiplex destinations on the
 * same input binding. For example, in the case of a comma separated multiple
 * destinations, the core framework will skip binding them individually if this is set
 * to true, but delegate that responsibility to the binder.
 *
 * By default this property is set to `false` and the binder will individually bind
 * each destinations in case of a comma separated multi destination list. The
 * individual binder implementations that need to support multiple input bindings
 * natively (multiplex) can enable this property. Under normal circumstances, the end
 * users are not expected to enable or disable this property directly.
 */
private boolean multiplex;

Последнее предложение неверно;Вы должны установить его, чтобы включить его.