Spring Cloud Stream разные настройки параллелизма для двух разных групп не работают

Question

Я настроил настройку параллелизма по умолчанию, и у меня есть другая группа, которой нужен другой уровень параллелизма, но вторая по умолчанию использует параллелизм по умолчанию 1 независимо. Это работало нормально с весенней загрузкой 1.5.4 и springCloudVersion Dalston.SR4. Текущие версии - это spring-boot 2.0.4, а springCloudVersion - это Finchley.SR1. Я использую rabbitMQ.

spring.cloud.stream.default.group=foo spring.cloud.stream.default.consumer.concurrency=3

У меня есть другая пользовательская группа

spring.cloud.stream.bindings.customChannel.group=bar spring.cloud.stream.rabbit.bindings.customChannel.consumer.concurrency=5

Все каналы в группе foo равны 3. Однако по умолчанию параллелизм для customChannel равен 1. Кто-нибудь сталкивался с подобной проблемой с обновлениями?

Answer 1

Там должно быть что-то еще происходит; это прекрасно работает для меня:

@SpringBootApplication
@EnableBinding(So52172152Application.Foo.class)
public class So52172152Application {

    public static void main(String[] args) {
        SpringApplication.run(So52172152Application.class, args);
    }

    @StreamListener("one")
    public void listen1(String in) {

    }


    @StreamListener("two")
    public void listen2(String in) {

    }

    @StreamListener("three")
    public void listen3(String in) {

    }

    public interface Foo {

        @Input
        MessageChannel one();

        @Input
        MessageChannel two();

        @Input
        MessageChannel three();

    }

}

и

spring.cloud.stream.default.group=foo
spring.cloud.stream.default.consumer.concurrency=3

spring.cloud.stream.bindings.three.group=bar
spring.cloud.stream.bindings.three.consumer.concurrency=5

И я вижу 3 потребителя в каждой очереди группы foo и 5 в группе столбцов.