【问题标题】:Spring Cloud Stream kafka producer, producing to dynamic kafka topicSpring Cloud Stream kafka 生产者,生产到动态 kafka 主题
【发布时间】:2020-02-10 02:15:44
【问题描述】:

我想使用spring cloud stream框架创建一个kafka端点,它将有一个http post api到/{topic_name}。如何动态更改spring.cloud.stream.bindings.<channelName>.destination={topic_name}属性

我可以使用confluent Kafka REST Proxy 实现来实现上述功能,但想知道它是否有可能在春季开发。

【问题讨论】:

    标签: spring-cloud-stream


    【解决方案1】:

    以下示例演示了这些类型的用例,其中它使用基于 http 触发器的动态目标。 查看代码和 README。

    https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/source-samples/dynamic-destination-source-kafka

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2018-08-29
      • 1970-01-01
      • 2017-02-05
      • 1970-01-01
      • 2021-10-23
      • 1970-01-01
      • 2018-01-08
      相关资源
      最近更新 更多