如何随时存储有效载荷以备后用

Question

我已经使用 Docker 部署了 spring-cloud-dataflow。这些是用过的容器：

springcloud/spring-cloud-dataflow-server-local:1.7.0.RELEASE
wurstmeister/zookeeper
wurstmeister/kafka:1.1.0

[问题中未涉及的其他容器...]

参考文档：

https://docs.spring.io/spring-cloud-dataflow/docs/1.7.0.RELEASE/reference/htmlsingle/

I am trying to create a stream in which i need to store the payload to use it later.

http | groovy-transform | httpclient_get: httpclient | httpclient_post: httpclient | log

有什么方法可以解决这个需求？

Answer 1

从您的笼统描述中不清楚最佳方法是什么。几个选项：

扇出get和post

http | groovy-transform > :request
:request > httpclient-get |log
:request > httpclient-post|log

可以加入的流：

 http | groovy-transform > :request     
 :request > httpclient-get > :response     
 :request > httpclient-post > :response
 :response > log

使用 Header enricher 处理器将原始负载添加为 header 以及一些代码以提取 httpclient_post 中的 header。

请注意，如果您在 kafka < 0.11 客户端上使用 kafka binder，则需要显式启用 custom headers：例如：

stream create hetest --definition "time | header-enricher --headers=foo='bar' | log --expression=headers"    
stream deploy hetest --properties "app.*.spring.cloud.stream.kafka.binder.headers=foo"

如何随时存储有效载荷以备后用

How to store the payload at any point to use it later

spring-cloud-dataflow