Spring云流的动态目的地-Kafka
我正在开发一个路由器（事件代理）应用程序与Spring云流在Kafka，在功能范式。应用程序从不断输入的主题消耗，映射和过滤消息，然后应该根据一些输入字段将其发送到某个主题（一次只有单个消息，而不是多个结果）。
最好的方法是设置Spring。云流动发送到。输出消息的目标标题？如果是这样，我应该如何为生产者设置绑定？
共有1个答案
您还可以在绑定配置方面使用StreamBridge。如果它们是真正动态的，而您不知道目的地的名称（例如，可能带有消息头），那么在配置它方面您无能为力。如果它们是半动态的，您确实知道名称，并且是一组有限的名称，那么您可以将其配置为任何其他绑定。例如，假设您正在向目标发送foo，而您可以使用spring。云流动绑定。foo
-
我想使用bean向Kafka发送带有在运行时解析的主题名称的消息。我的问题是，本主题的中的默认值为1。 当Kafka中已经存在此主题时，以及当客户端创建此主题时（分区计数等于配置值），此值并不反映真正的分区数。 如何使此属性反映分区的真实数目？
-
我正在尝试使用Spring Cloud Stream处理发送到Azure Event Hub实例的消息。这些消息应该路由到Kafka集群上运行时根据消息内容确定的租户特定主题。出于开发目的，我通过Docker在本地运行Kafka。我对配置时未知的绑定进行了一些研究，发现动态目标解析可能正是我在这个场景中所需要的。 然而，让我的解决方案工作的唯一方法是使用。我宁愿使用动态目标标头，这样处理器就可以被
-
我们在Spring Cloud Stream上有一个应用程序，它与Project React集成在一起。我们通过在消息标题中设置spring.cloud.stream.sendto.destination来动态设置目标主题并发布消息。我们正在寻找处理错误的情况下，如Kafka服务器断断续续或主题不可用而发布。我们已经实现了@ServiceActivator来处理所有错误。动态设置主题时，Servi
-
我正在使用Spring Cloud Stream，希望以编程方式创建和绑定通道。我的用例是，在应用程序启动期间，我收到要订阅的Kafka主题的动态列表。然后如何为每个主题创建频道？
-
我正在尝试用《Spring的云流》和《Kafka》。下面是示例代码。但它似乎没有任何作用。它总是创建一个名为“输出”的主题。但这些价值观尚未公布。 应用亚马尔 我的目标就是创造价值。 依赖性-2.2.6。释放
-
我想创建一个公共项目（使用spring cloud stream），根据消息内容动态地将消息路由到不同的（消费者）项目。（rabbitmq作为消息代理） spring cloud stream支持吗？如果没有，有什么建议的方法来实现这一点？thx公司