带有春天云流的动态目的地 - Kafka答案

【问题标题】：Dynamic destination with spring cloud stream - Kafka带有春天云流的动态目的地 - Kafka
【发布时间】：2021-12-30 13:45:20
【问题描述】：

我正在开发一个路由器（事件代理）应用程序，该应用程序使用 Kafka 上的 spring 云流，在功能范式中。应用程序从常量输入主题中消费，映射和过滤消息，然后应根据某些输入字段将其发送到某个主题（一次只有一条消息，而不是多个结果）。

最好的方法是为输出消息设置spring.cloud.stream.sendto.destination 标头吗？如果是这样，我应该如何为生产者设置绑定？

【问题讨论】：

请提供足够的代码，以便其他人更好地理解或重现问题。

标签： apache-kafka spring-kafka spring-cloud-stream spring-cloud-function

【解决方案1】：

您也可以使用StreamBridge 关于绑定配置。 . . 如果它们是真正动态的，而您不知道目的地的名称（例如，可能带有消息头），那么在配置它方面您无能为力。如果它们是半动态的，您确实知道名称并且它是一组有限的名称，那么您可以将其配置为任何其他绑定。例如，假设您要发送到目的地foo，那么您可以使用spring.cloud.stream.bindings.foo.....

【讨论】：