SCDF自定义Spring-Cloud-Stream源应用程序不将生成的消息写入Kafka主题

Question

我用kafka绑定器创建了一个简单的spring cloud流“源”和“汇”应用程序，并在SCDF（spring cloud Data Flow）中注册了JAR。

在SCDF（source-app sink-app）中创建了steam，并成功地部署了该流。

我的源应用程序很简单，代码如下：

@GetMapping("send-it")
@SendTo(Source.OUTPUT)
public Message<String> out() {

    final Message<String> test_test =
            MessageBuilder.withPayload("appTestName: " + "demo" ).build();
    System.out.println("Sending message ....");
    return test_test;

}

在类级别上使用了@EnableBinding(Source.class)、@RestController。

Answer 1

创建名为“steam-name.sourceapp-name”的主题确认SCDF正确配置了源应用程序。您可以尝试在Kafka客户机和Spring Kafka包中启用更多的调试日志记录，以查看发布到主题的消息时发生了什么。