如何让Spring Cloud Stream App Starter httpclient处理器将错误消息从api响应发送到日志接收器？

文章/答案/技术大牛

发布

0回答

java、spring、spring-cloud-stream、spring-cloud-dataflow

当我检查httpclient处理器的stdout日志时，我发现当我发出请求时会得到一个422响应。随响应一起发送的实际错误消息丢失了，或者至少我不确定如何找到它。是否可以将json响应发送到日志接收器，以便对请求进行故障排除？

浏览 1提问于2017-06-18得票数 0

2回答

Spring数据流自定义Scala处理器无法从初学者应用程序发送/接收数据(SCDF 2.5.1和Spring 2.2.6)

scala、spring-boot、spring-cloud-stream、spring-cloud-dataflow、spring-cloud-stream-binder-kafka

我一直在为Spring数据流在Scala中创建一个简单的自定义处理器，并遇到了从/向初学者应用程序发送/接收数据的问题。我无法看到任何消息在流中传播。(platform("org.springframework.cloud:spring-cloud-stream-dependencies:Horsham.SR5")) implementation("("org.springframework.

浏览 3提问于2020-06-11得票数 0

回答已采纳

1回答

当使用春云数据流时，找不到sftp源starter应用程序file_name头

spring-cloud、spring-cloud-dataflow、spring-integration-sftp

spring cloud dataflow sftp source starter app (mode=contents)。但是，当我将这个源连接到日志接收器时，我看到一些头(如Content-Type)，但看不到file_name头。我想使用这个头将文件以相同的名称上传到S3。spring服务器：Spring Cloud Data Flow Local Server (v1.2.3.RELEA

浏览 8提问于2017-12-20得票数 0

1回答

spring云启动程序:流-处理器-任务启动请求-转换忽略本地maven设置。

maven-3、spring-cloud-stream、spring-cloud-dataflow

在我的云流应用程序中，我使用了spring-cloud-starter-stream-processor-tasklaunchrequest-transform初学者应用程序作为任务处理器。:spring-cloud-starter-stream-processor-tasklaunchrequest-transform:jar:1.1.0.BUILD-SNAPSHOT` 2.在处理器日志中记录的<

浏览 4提问于2016-11-04得票数 0

回答已采纳

1回答

在中实现Avro

avro、spring-cloud-stream、spring-cloud-dataflow

我正在尝试实现流，它从数据库中读取记录，将这些记录传递给处理器，后者将转换为Avro模式，然后将其传递给接收器应用程序使用。我将数据从SQL DB传输到我的源应用程序，并通过Kafka绑定程序传递数据，没有问题，我正在将数据从处理器发送到Sink应用程序，使用Avro序列化/反序列化。我已经将以下依赖项添加到处理器和接收器的pom中

浏览 3提问于2017-11-20得票数 0

回答已采纳

1回答

弹簧集成:粘合剂配置(用于兔子)

spring-cloud-stream

我正在尝试将Spring集成应用程序配置为中间件。/artifact/org.springframework.cloud/spring-cloud-starter-stream-rabbit // h

浏览 0提问于2019-07-12得票数 0

1回答

SpringCloudStream-HttpSource返回404

spring-cloud、spring-cloud-stream

我的用例是具有多个接收器的HttpSource。当我将Starter App依赖项添加到应用程序并使用它时，如下所示： <groupId>org.springframework.cloud.stream.app</groupId> <artifactId>spring-cloud-

浏览 1提问于2016-10-28得票数 0

1回答

如何在Spring* Cloud *Stream聚合器处理器的aggregator.aggregation选项上使用SpEL表达式？

spring、spring-cloud-stream、spring-cloud-dataflow

,}"id": "1234",type": "space-crite", "ferocity": 10, &quo

浏览 1提问于2017-06-11得票数 0

2回答

春云流头丰富了循环参考和NPE

spring-cloud-stream、spring-cloud-dataflow

使用Spring数据流服务器和Kafka绑定器shell 1.3.0.M1，并从Bacon位-ly URL (1.2.0.RELEASE)加载应用程序。我在shell中创建/部署了一个流：并在标头中接收异常org.springframework.beans.factory.BeanCreationException: Error creating bean wit

浏览 3提问于2017-08-29得票数 0

回答已采纳

2回答

了解Stream内容类型

spring-cloud-stream、spring-cloud-dataflow

按照Q&A中的指导，我的自定义处理器有一个包含以下内容的application.properties文件：spring.cloud.stream.bindings.input.content-type=application/json;com.company.InputDto

浏览 0提问于2017-08-24得票数 0

回答已采纳

1回答

源/处理器/Sink消息传递(java.util.HashMap)

spring-cloud-stream、spring-cloud-dataflow

<groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream

浏览 1提问于2018-06-10得票数 0

1回答

春云数据流errorChannel不工作

kubernetes、spring-integration、spring-cloud-stream、spring-cloud-dataflow

这是Spring集成错误路由器的代码：import org.springframework.cloud.stream.annotation.EnableBinding=zklistArgs: --spring.cloud.stream<

浏览 0提问于2018-11-27得票数 0

回答已采纳

1回答

春数据流将消息从一个兔子VHost移动到另一个

spring、spring-cloud-dataflow、spring-rabbit

TLDR:似乎无法将消息从一个RabbitMQ VHost传递到另一个RabbitMQ VHost。但是，ExchangeBlah上的vHostB上没有消息，我在RabbitMQ Sink日志中看到错误，上面写着：我觉得这可能与Spring环境变量有关

浏览 4提问于2019-05-20得票数 0

回答已采纳

1回答

用通过JMS启动Spring批处理作业

spring-boot、spring-batch、spring-cloud-dataflow

我有一个应用程序，它在接收消息时侦听activeMQ队列并启动批处理作业。我想使用来提供一个UI，但是我找不到关于如何配置它的信息。由于它使用Spring，所以我应该能够复制我的应用程序当前的工作方式(使用REST让它侦听activeMQ并在接收消息时启动作业)，但是我找不到任何关于如何让它在Cloud中启动批处理的内容。

浏览 4提问于2022-03-02得票数 0

2回答

Spring，在错误状态响应主体上，错误消息为空

spring-mvc、exception、service、spring-restcontroller

在我的Spring上，我想通过抛出一个自定义异常向响应体传递一个自定义错误消息。/create-rfq"我只想要"message": "User Not Found",

浏览 8提问于2020-06-24得票数 15

回答已采纳

2回答

Spring数据流错误:无法访问jarfile

spring-boot、spring-cloud-stream

我在这个网站上发布了基于的Spring云数据流。我在Spring数据流云仪表板上注册了它们。然后，我创建了一个流，其中源连接到处理器，连接到接收器。当我部署应用程序并打开{流名}时，{testdir-stream.sender1-v3: "Error: Unable to access jarfile /testdir=zookeeper:2181 -

浏览 0提问于2019-09-09得票数 0

回答已采纳

1回答

如何配置DeadLetterPublisherRecoverer在Stream批处理模式下向DLQ发送错误消息

java、spring、spring-kafka、spring-cloud-stream、spring-cloud-function

我使用和Spring函数创建了一个Kafka消费者，用于批量消费来自Kafka主题的消息。现在，我希望将错误批次发送到死信队列中，以便进一步调试错误。我正在用Spring重试处理我的使用者方法中的重试。但是对于不可重试的异常，我希望将整个批处理发送到DLQ。{ }使用DeadRecordPublishinRe

浏览 9提问于2022-07-11得票数 0

2回答

为SCDF对流应用进行Docker化

spring-cloud-stream、spring-cloud-dataflow

我已经能够在Kubernetes集群中设置spring cloud dataflow 1.2.0.RELEASE，导入starter应用程序，并运行简单的流程，如"http | log“。但是当我尝试在像"http | myApp | log“这样的流中运行我自己的Dockerized stream应用时，我似乎无法让它工作……部署很好，流的Kafka主题是按照预期创建的，没有来自任何pod的错误消息，但是myApp处理器似乎不知道

浏览 2提问于2017-08-11得票数 0

1回答

StreamBridge绑定，而不是自Spring* 3.1版本以来就不再推荐的EnableBinding和输出注释*

java、spring、avro、spring-cloud-stream、spring-cloud-stream-binder-kafka

我有多个API，可以通过kafka (产生和消费消息)相互交谈。在其中一个API中，我根据HTTP请求触发器(当一个端点被调用时，生成一个meesage并发送到kafka)使用@Output和@EnableBinding注释生成消息。这些会议由订阅此主题的其他API使用。现在，我尝试迁移到新的模型，从文档中我得出结论，使用外部源数据的StreamBridge是我的案例所需要的方法()。我有以下配置，它成功地在"myFooTopic“上生成消息</em

浏览 8提问于2022-03-08得票数 1

1回答

从Azure事件中心到Kafka的春季云流的动态目的地

apache-kafka、spring-cloud-stream、azure-eventhub

我试图使用来处理发送到Azure事件中心实例的消息。这些消息应该被路由到Kafka集群上基于消息内容在运行时确定的特定租户主题。出于开发目的，我通过Docker在本地运行Kafka。我宁愿使用动态目标头spring.cloud.stream.sendto.destination，这样处理器就可以编写成Function<>而不是Consumer<> (它不是一个接收器)。我还试图提供一个NewDestinatio

浏览 14提问于2022-01-20得票数 2

回答已采纳

点击加载更多