Как сохранить полезную нагрузку в любой момент, чтобы использовать ее позже

Question

Я развернул весенне-облачный поток данных с помощью Docker.Это используемые контейнеры:

• 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/

---

Я пытаюсь создать поток, в котором мне нужно сохранить полезную нагрузку, чтобы использовать ее позже.

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

Есть какой-то способ решить эту проблему?

Answer 1

Из вашего общего описания не ясно, каким будет лучший подход.Пара опций:

1. Разветвление для получения и отправки

   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 , чтобы добавить исходную полезную нагрузку в качестве заголовка вместе с некоторым кодом для извлечения заголовка в httpclient_post.

Обратите внимание: если вы используете подшивку kafka с клиентом kafka <0.11, вам нужно явно включить <a href="https://docs.spring.io/spring-cloud-stream/docs/current/reference/htmlsingle/#_kafka_binder_properties" rel="nofollow noreferrer"> пользовательских заголовков : Например:

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"