Я развернул весенне-облачный поток данных с помощью Docker.Это используемые контейнеры:
- springcloud / spring-cloud-dataflow-server-local: 1.7.1.RELEASE
- wurstmeister / zookeeper
- wurstmeister / kafka: 1.1.0
[другие контейнеры, не вовлеченные в проблему ...]
Документация, к которой обращались:
SpringСправочное руководство по потоку данных в облаке - 1.7.1.RELEASE
Процессор обогащения заголовка
Я пытаюсь использовать процессор обогащения заголовка для добавлениянесколько заголовков, но я могу добавить только один заголовок.
В следующем примере:
time | header-enricher --headers="foo='bar' \n baz='qux'" --overwrite=true | log --expression=headers
Также добавьте это свойство в развертывание
app.*.spring.cloud.stream.kafka.binder.headers=foo,baz
Журнал обогащения заголовка генерирует следующую ошибку при запуске.
Вложенное исключение - org.springframework.beans.BeanInstantiationException: Не удалось создать экземпляр [org.springframework.integration.transformer.support.ExpressionEvaluatingHeaderValueMessageProcessor]: циклическая ссылка с участием conan bean 'org.springframework.cloud.stream.app.header.enricher.processor.HeaderEnricherProcessorConfiguration' - рассмотрите возможность объявления метода фабрики как статического для независимости от содержащего его экземпляра.Фабричный метод «процессор» бросил исключение;вложенное исключение: org.springframework.expression.spel.SpelParseException: EL1041E: После анализа допустимого выражения в выражении еще больше данных: 'baz'
РЕДАКТИРОВАТЬ: В настоящее время я использую эти два способа определения потока.
- Панель инструментов SCDF : выдается следующая ошибка
SCDF Shell spring-cloud-dataflow-shell-1.7.2.RELEASE Выдает следующую ошибку и кажется, что он не принимает символ \
Оболочки Котировки и побег
