《stream》专题

根据我在这里读到的内容，我试图确保Spring Cloud Sleuth跟踪ID作为标题发送到Kinesis上。如果我正确阅读了这里提供的Spring Cloud Kinesis binder文档，我认为下面的配置、生产者和消费者代码将允许X-B3-TraceId头从生产者成功发送到消费者。但是，这目前不起作用，因为标头在使用者端不可用。使用AWS Kinesis活页夹，如何将此标题从生产者传递给

我们有一个流氓生产者将Kafka Header设置为一个类，该类是生产者的一部分，但不是使用Kafka Streams绑定器在Spring Cloud Stream应用程序中实现的消费者的一部分。它导致了一个异常

我有一个Spring boot应用程序，我使用spring-Cloud-stream从一个kafka主题中消费，进行一些处理并发布到另一个kafka主题。该应用程序运行良好，我已经编写了运行良好的单元测试（使用TestBinder）。 我现在正试图用嵌入式Kafka编写一个集成测试，并测试端到端的功能。我在这里跟踪了样本https://github.com/spring-cloud/spring-

根据文件https://spring.io/projects/spring-cloud-stream没有Artemis/ActiveMQ绑定器/实现？ 有计划吗？ RabbitMQ 阿帕奇Kafka Kafka流 亚马逊运动 Google PubSub（合作伙伴维护） Solace PubSub（合作伙伴维护） Azure事件中心（合作伙伴维护） Apache RocketMQ（合作伙伴维护） 谢

我不确定我的理解是否正确。我们启动了一个Spring云流应用程序并订阅了一个主题。该应用程序将运行并暂停该主题以获取新消息，除了我们发送终止信号退出。我在想我们是否可以明确退出Spring云应用程序，比如等待5分钟但没有新消息进来？或者处理了1000条记录并退出？

当尝试运行稍微修改过的word count示例版本时，我遇到了一个错误，即“没有符合条件的'org.apache.kafka.streams.kstream.KStreamBuilder'类型的bean”。在我的POM中，我使用了Spring-Cloud-Stream依赖项：Elmhurst。M3导入依赖项，其中导入了spring cloud stream绑定器kstream:2.0.0。立方米。

需要将KTable与Spring Kafka活页夹配置一起使用，以下是用于从主题中读取数据并在控制台上打印的示例代码。 但应用程序以Throw java终止。lang.IllegalArgumentException：方法在应用程序启动时必须是声明性的。 引用Spring Cloud Stream Kafka-方法必须是声明式的，结果仍然保持不变 Java-11 活页夹： 监听器 控制台输出：

我们需要从一个主题中获取消息，然后进行一些扩展，然后将消息发布到另一个主题。以下是活动 消费者-消费信息 丰富-丰富了消费的信息 制作人-将丰富的信息发布到其他主题 我正在使用Spring Cloud kafka绑定器，一切正常。最近我们引入了幂等生产者并包含transactionIdPrefix属性，我们观察到出站通道开始在主题中发送2条消息，因为它应该只发送一条消息。一条具有实际json值的消

我正在编写一个将处理事件消息的应用程序（发布到主题）。我有多个endpoint应该使用这些消息（和），出于实用的原因，我想将这些endpoint一起部署在一个聚合包中。 有了Spring Cloud Stream，我可以使用Spring。云流动绑定。文件上载已完成。group=元数据读取器，为第一个endpoint设置消费者组；我还想在配额检查组下处理消息，但基于属性的配置只允许每个消息队列绑定一

我有Spring Cloud Stream Rabbit项目，它将消息发送到兔子交换以防流中出现错误。我想定期（5分钟一次）从队列中监听并处理它。 有什么方法可以让我有一个可轮询的？或者我可以配置一个RabbitMQ，这样我就可以用轮询器构建一个？

我已经创建了一个Spring Cloud数据流，它使用Spring Cloud Stream starter应用程序中的router sink应用程序。我使用的是带有RabbitMQ绑定的。这会自动使用我的路由器表达式的结果创建RabbitMQ交换（类型：topic）。我认为下一步是为每个路由器结果创建新的数据流。但是，rabbit source starter应用程序只能配置为从队列中读取。当然

我开发了spring批处理应用程序，该应用程序生成由json对象列表组成的amqp（rabbitmq）消息。消息具有包含一些元数据的标头。Spring cloud stream应用程序正在消费消息，我使用了功能性方法。如何访问标题<将消息头用于除路由之外的任何内容，这是一种糟糕的方法吗？

下面的代码适用于小文件( 我得到： 19161088 HTTP响应（_body=无，缓冲区= 使用Python下载时，但是 0 HTTPResponse（_body=None，buffer=None，code=599，effective_url=）http://releases.ubuntu.com/16.04.1/ubuntu-16.04.1-desktop-amd64.iso?_ga=1.17

我试图在一个集合的单个文档中侦听更改，但无法使其正常工作。 我正在使用。方法，但我只获取一次文档。如果我在Firebase控制台中更改数据，除非重新打开视图，否则不会更新任何内容。 有没有办法做到这一点？

我试图在spring cloud stream中实现延迟消息（不使用rabbitmq插件），但它不起作用 我使用sping-boot实现了它，它工作得很好。下面是我在sping-boot中做的示例代码。 RabbitMQ中的延迟消息 我正试图在Spring的云流中做同样的事，但没有任何帮助。以下是属性。 输出通道-生产者 输入通道-消费者 当用spring boot实现时，我看到消息在指定的时间内