Tag: spring xd

SpringXD和Spring Integration：每隔X分钟从kafka主题中读取一遍，然后发送到另一个主题

我正在尝试实现一个解决方案来创建一个由kafka源，桥接模块和kafka接收器组成的SpringXD流。 所以我有类似的东西： 我的问题是我想以某种方式避免使用轮询器。 基本上是因为当这些消息在队列中时我想避免将消息保留在内存中。 我宁愿每隔X分钟从kafka读取一次，只需从队列中取出Y消息，然后将这些消息发送到下一个主题。 看起来我无法摆脱队列，但后来我的问题是：还有其他选择吗？ 我不喜欢把东西留在内存中，但我也不想使用这个选项： http ： //docs.spring.io/spring-integration/reference/html/system-management-chapter.html#message -商店

Spring Batch – 从Aws S3读取文件

我正在尝试从AWS S3读取文件并使用Spring Batch处理它： Spring Itemreader可以处理此任务吗？ 如果是这样，我如何将凭据传递给S3客户端并配置我的spring xml以读取文件或多个文件