问题标签 [spring-xd]

我使用 redis 作为 spring-xd 分布式环境的消息存储。

我将消息头设置如下，

在检查处理器中收到的消息时，它只显示 id 和时间戳

发送时的标头

收到的标头

这里的 id 和时间戳是不同的，但有效负载是相同的。

请帮我解决这个问题，

在此先感谢，-Suyodha

我有一个问题是如何使用多处理器创建流。例如：

或者

请告诉我该怎么做？谢谢 ！

我需要从多个来源定义多个流，然后将它们合并为一个。在阅读了 Spring XD 的整个文档之后，我没有找到任何可以进行连接的预定义模块（例如基于滑动窗口）。有什么解决办法吗？谢谢。

我试图用这个定义创建一个流：

它抛出了这个错误：

我浏览了文档，但无法弄清楚它失败的原因。

当我运行时"info"，我也没有看到--properties-location列出的属性：

知道如何解决这个问题吗？

使用 Spring XD 的接收器 MQTT 源模块，我在有效负载上得到错误的值。我让流订阅了某个主题，而 Eclipse 中的普通客户端也订阅了相同的主题。有效载荷应该是一个字节数组。对于我收到的相同消息

xxxxx...0000073F，在 Spring XD 上

xxxxx...000007F9，在 Eclipse Paho 客户端上

实际上，这个值应该是一个计数器，并且 eclipse paho 客户端表现得很好，但是当任何十六进制数字达到 F 时，Spring XD 似乎表现得很奇怪。出于同样的原因，它会卡在同一个数字上，直到计数器已经增加到足以消除序列上的任何 F。

我的问题是，如果 Spring XD 上提供的 MQTT 客户端上发生任何预处理，这解释了为什么我在有效负载上得到不同的值。我确信第二个是正确的，因为发送值的是我自己。

谢谢。

Spring XD 为启动批处理作业提供了平台。这是否涵盖了所有批处理作业用例的综合工作流程？或者它打算在 Spring XD 用例的上下文中使用。

例如，如果某人只想使用 spring-batch 不一定要使用数据摄取/实时分析的所有功能，他们是否仍会通过设置 Spring XD DIRT 来执行批处理工作流而受益？在这种情况下，是否有任何限制不能使用 spring-batch 支持的所有批处理工作流？

我正在尝试使用 YAML 文件将配置属性外部化。我成功地读取了属性并使用 Spring Boot 应用程序单独运行它。

但是当我在我的 Spring 批处理作业项目中集成相同的类并尝试部署该作业时，我得到了以下异常。异常是什么意思？如何禁用不正确的类转换？

这些是我的 Maven 依赖项：

在 Windows 平台上运行 Spring XD 的最佳实践是什么？

我所看到的大部分内容只是从命令行运行它。这对演示很有用，但在生产环境中效果不佳。是否可以创建 Windows 服务来启动和停止 Spring XD 进程？或者还有什么可以用来管理 Spring XD 运行时。

实际上，这可以应用于任何嵌入式 tomcat 应用程序。

在分布式设置中，如何以编程方式启动容器？

更具体地说，是否存在类似于部署和取消部署流的 API 来设置和拆除容器？

I have set the environment variable spring.profiles.active to "qa" which is the profile in application.yml file which i want to activate.

But after setting this environment variable, and starting Sprind XD in xd-singlenode, it throws me the following exception

What might be the exception ?? Any help will be greatly appreciated.

Thanks