在春季集成流中获取动态文件
如何在弹簧集成流中配置动态文件名? 方案:在FTP上,每天文件都会生成当前日期。通过SFTP,需要读取当前日期文件。 示例: *_20220525_data.txt, *_…
春季集成kafka侦听器线程读取多个分区时,当并发=分区计数
我设置了一个弹簧集成流,以处理一个具有3个分区的主题,并将侦听器容器的并发设置为3。但是,我看到在某些情况下,其中一个侦听器线程可能会处理包含…
如何处理具有Spring Integration的大型ZIP文件的副本
该主题类似于:从ftp 但是没有明确的答案,这里的情况并不完全相同。 我在一台服务器上有一个输入目录,该目录将从另一台远程服务器复制到zip文件中。…
春季集成 - 延迟器在使用JDBCMESSAGESTORE和MYSQL时开始发送零消息有效载荷,可与H2一起使用
我的流量以下是很好的流程,直到我将Messagestore添加到延迟器部分(以获取持久消息)。这一切都与嵌入式H2数据库一起使用。如果我切换到MySQL数据库…
防止使用春季集成多次对消息进行调查吗?
我使用的是春季集成, jpapollingchanneladapter 从数据库中带有某个状态的民意测验。如果找到条目,则将处理这些条目。 我想知道是否有任何方法可以…
带有DSL Kafka的Kafka嵌入式服务器。
我正在使用Kafka消息驱动的通道适配器来阅读KAFKA主题的消息。它可以正常工作,但是当我使用嵌入式Kafka经纪人进行集成测试时,它不起作用,也不听取…
春季集成 - 如何使用kotlin DSL根据标头值路由
假设我有一个标题,上面有一个名为“计数”的属性,我该如何根据该值路由? 在Kotlin DSL中有路由函数,但是我不确定如何将其配置为 HeaderValueroute…
Spring集成是实现交易量输出模式的好框架吗?
Closed. This question is opinion-based. It is not currently accepting answers. 想要改进这个问题吗?更新问题,以便可以通过 闭合 2年前。…