是否可以为特定方法禁用spring cloud stream的功能绑定？

Question

我有一个基于Spring Boot的库（使用spring-data-mongo），它创建了一个PeristentEntitiesbean。PeristentEntities碰巧实现了供应商

我们使用的是Spring Cloud Streams Kafka绑定器，因此Spring尝试将这些对象中的每一个发布到它创建的Kafka主题。这会在JSON序列化程序中导致无限递归问题：

2019-12-04 15:36:54.323ERROR 1 --- [ 调度-1]o. s. i. h. LoggingHandler：org.springframework.messaging.MessagingException：调用方法失败；嵌套异常org.springframework.messaging.converter.MessageConversionException：无法写入JSON：无限递归（StackOverflow Error）（通过引用链：org.springframework.data.mongodb.core.mapping.BasicMongoPeristentEntity["idProperty"]-

有没有办法从函数绑定中排除我的bean？使用此库的项目没有使用Spring Cloud Function，但我更愿意保留这种可能性。

作为参考，my bean的定义如下：

@Bean
public PersistentEntities myPersistentEntities(List<MongoTemplate> mongoTemplates) {
    return new PersistentEntities(() -> {
        List<MappingContext<?, ?>> mappingContexts = mongoTemplates.stream().map(t -> t.getConverter().getMappingContext()).collect(Collectors.toList());
        return mappingContexts.iterator();
    });
}

我们刚刚将Spring Cloud从Greenwich升级到Hoxton，因此自动功能绑定对我们来说是新的。




Answer 1

所以，我遇到了类似的事情。TL；DR fix明确定义了Spring云流可用的函数，如下所示：

消费者Bean名称：inputConsumer

spring:
  cloud:
    stream:
      function:
        bindings:
          inputConsumer-in-0: DataInputBinding
        definition: inputConsumer
      bindings:
        DataInputBinding:
          binder: kinesis
          destination: whatever
          group: whatever

在我的情况下，我的应用程序有另一个spring组件，它实现了供应商。Spring Cloud Streams没有在配置中明确定义函数，只是将所有功能、消费者和供应商bean添加到FunctionCatalog，然后期望所有这些bean都连接到流。

显然，如果它们没有，那么它就不会连接任何一个，任何东西都不起作用/

Answer 2

匿名用户

通常，您可以通过将spring云函数显式排除为

@SpringBootApplication(exclude = ContextFunctionCatalogAutoConfiguration.class)

也就是说，请提出一个问题——https://github.com/spring-cloud/spring-cloud-stream/issues.以前已经出现过这种变体，我开始相信我们需要一个比上述更好的解决方案。

另一种解决方法是显式指定spring。云作用定义=blah属性，其中blah是不存在的东西。很难看，但确实如此，而且它不需要重新编译，因为不涉及任何注释或其他属性。

但正如我所说，请提出一个问题，链接到这篇文章，我们将在年底前为SR1解决这个问题。