Spring 云数据流:兔子源 |转换为 GPB |日志接收器

Spring Cloud Dataflow: Rabbit Source | Transform to GPB | Log Sink

现在,我正在尝试使用 Spring Cloud Dataflow,我有一个用例,我们想将 RabbitMQ 消息总线上的流量记录到日志文件中。

我的第一次尝试很简单:

create --name test --definition "rabbit | log" --deploy

运行 这我能够看到 ASCII 输出到日志文件。但是,我会将 RabbitMQ 传输的消息(Google 协议缓冲区)的内容转储到日志文件中。所以,我想我可以做类似的事情:

create --name test --definition "rabbit | transform=new Envelope.parse(payload.toBytes()) | log

(这是一个次要的细节,但是,我所有的 GPB 消息都被一个通用的 class "Envelope" 封装)。

如何将 GPB class 的 .jar 文件包含到 Spring Cloud Dataflow 中? 或者有更好的方法吗?

如果您的类路径需要额外的 类,您必须配置应用程序以包含它们。查看应用程序启动器的文档,了解如何使其正常工作:http://docs.spring.io/spring-cloud-stream-app-starters/docs/Bacon.RELEASE/reference/html/