1

我正在尝试在同一应用程序中使用来自不同 PubSub 主题的多条消息。其中一个是轮询的，其他的应该是功能绑定。我的功能消费者不工作。

@Bean
public Consumer<MessageA> messageAMessageHandler() {
    return message -> { ... }
}

@Scheduled(initialDelay = 60 * 1000, fixedRate = 600 * 1000)
public void pollBMessages() {
    this.bMessageSource.b().poll(m -> { ... }, new ParameterizedTypeReference<MessageB>() {
    });
}

我的应用程序.yml：

spring:
  cloud:

    stream:
      pubsub:
        default:
          consumer:
            auto-create-resources: true

      gcp:
        pubsub:
          bindings:
            message-a-input:
              consumer:
                ack-mode: manual

      bindings:
        messageAMessageHandler-in-0:
          destination: message-b-topic
          group: my-service
        message-a-input:
          destination: message-a-topic
          group: my-service

    function:
      definition: messageAMessageHandler;messageCMessageHandler

轮询基于 MessageSource 的注解效果很好，但没有拾取功能绑定。它们是我的应用程序上下文中的 Bean，但云流或 gcp pubsub 会忽略它们。不创建订阅，也不消耗任何消息。

我错过了什么？

4

1 回答 1

3

由于您的轮询活页夹正在工作，您的代码中可能有@EnabledBinding注释。如果您查看应用程序输出，您将看到如下消息：

onConfiguration$FunctionBindingRegistrar : Functional binding is disabled due to the presense of @EnableBinding annotation in your configuration.

Spring Cloud Stream 不支持混合遗留（基于注释）和功能绑定样式。

于 2020-05-06T18:56:02.783 回答