从Spring Cloud Stream MessageChannel获取主题名称

Question

我们在Spring Boot应用程序中使用Kafka Cloud Stream向Kafka发送数据。这样地

producerChannel.send(MessageBuilder
                    .withPayload(data)
                    .setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
                    .build())

我想知道除了直接从 yaml 文件中读取之外，是否可以从消息通道获取主题名称？

@Output("topic-name-out")
MessageChannel producerChannel();

主题名称存在于kafka.yaml中

spring:
  cloud:
    stream:
      bindings:
        topic-name-out:
          destination: topic_name_to_producer
          contentType: application/json
          producer:
            partitionCount: ${partition_count:3}

Answer 1

我看到您正在使用基于注释的编程模型（例如，@Outapp）。它已被弃用3年，正在从代码库中删除。请升级到功能模型。

至于您关于外部配置的目的地名称的问题，有一种方法可以通过绑定以编程方式访问它，但我更好奇的是，为什么需要它，因为它是一个内部细节，而且考虑到它是外部配置的，它可以在没有通知的情况下更改，从而影响您的代码。