Spring Boot 2.2.4 / Hoxton.SR1中的处理器应用程序在Spring Cloud Data Flow 2.4.1中不起作用

Question

我正在尝试开发一个新的应用程序以在SCDF 2.4.1和Skipper 2.3.1上工作

我从https://github.com/sabbyanandan/stream-programming-models

我在本地构建它们。下载了SCDF kafka的docker compose，设置了版本并挂载了我的仓库，然后启动了我的docker compose。

当我部署“功能”模块并创建简单流时http | customUpper |日志

我看到示例工作正常，并能够按预期看到日志输出。

当我修改函数流应用程序时，将Spring Boot，2.2.4和Hoxton.SR1用于云流依赖项。我在日志中看不到任何输出。

BootApp

public class FunctionStreamSampleApplication {

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

    @Bean
    public Function<String, String> uppercase() {

        return data -> {
            System.out.println("Input "+data);
            return data.toUpperCase();
        };
    }
}

application.yml
spring:
  cloud:
    stream:
      function:
        definition: uppercase

pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <artifactId>function219</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>function219</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-function-context</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-kafka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

我删除了测试类，只是将其剥离到最低限度，以避免其他依赖性。部署该应用程序时，与使用最初构建于其上的2.1.4版本的spring boot一样，可以正常工作。请告知是否需要进行更改以使其在SCDF上运行]

[当我使用kafkatools检查流创建的主题时，我仅在streamname.http中看到消息，但是由于我的sysout未被打印，处理器似乎没有在读取消息。

Answer 1

我相信问题在于，当前发布的流应用程序（http和日志）使用基于spring boot 2.1.x的spring-cloud-stream的早期版本。与引导2.2.x兼容的较新版本的spring-cloud-stream不向后兼容。流中的所有应用程序必须具有相同（或兼容）的spring-cloud-stream版本。我希望，如果您查看自定义处理器的日志，将会看到一些转换错误。