Я пытаюсь использовать преобразование с помощью сценариев с использованием javascript для анализа полезных данных json от кролика.Однако, получая ошибку.
Поток ОПРЕДЕЛЕНИЕ
rabbit --password = '******' --queues = springdataflow-q10 --host = 172.24.172.184 --virtual-host= springdataflow --username = springdataflow |scriptable-transform --language = javascript --script = 'function extract (a) \ n {\ n var obj = JSON.parse (полезная нагрузка); \ n return obj.customerId; \ n} \ nextract (полезная нагрузка);'|log
VERSION
Версия потока данных весеннего облака - 1.5.2, а версия преобразования -.maven: //org.springframework.cloud.stream.app: scriptable-transform-processor-kafka ‑ 10: 1.3.1.RELEASE
ERROR
Поток развертывается нормально, но наЖурналы для бита преобразования Я получаю странную ошибку: docker exec -it dataflow-server tail -f /tmp/spring-cloud-deployer-8103682307576658371/json-parse-js-1538777252915/json-parse-js.scriptable-transform/stdout_0.log at org.springframework.kafka.listener.adapter.RetryAcknowledgingMessageListenerAdapter.onMessage (RetriedAcknowledgingMessageListenerAdapter.java:73) ~ [spring-kafka-1.1.7.RELEASE.jar! /worker.kaf org.kaf или,792) [spring-kafka-1.1.7.RELEASE.jar! /: Na] на org.springframework.kafka.listener.KafkaMessageListenerContainer $ ListenerConsumer.invokeListener (KafkaMessageListenerContainer.java:736) [spring-kafka-1.1.7.RELEASE.jar! /: na] at org.springframework.kafka.listener.KafkaMessageListenerContainerContainer $ (ListenerContainer $ () [spring-kafka-1.1.7.RELEASE.jar! /: na] at org.springframework.kafka.listener.KafkaMessageListenerContainer $ ListenerConsumer $ ListenerInvoker.run (KafkaMessageListenerContainer.java:1025) [spring-kafka-1.1).RELEASE.jar! /: Na] в java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:511) [na: 1.8.0_111-internal] в java.util.concurrent.FutureTask.run (FutureTask.java): 266) [na: 1.8.0_111-internal] на java.lang.Thread.run (Thread.java:745) [na: 1.8.0_111-internal]
Спасибо за вашу помощь!