春云流和消耗多个kafka主题

我在尝试使用一个@StreamListener中的多个主题尝试spring-boot-stream时遇到问题。春云流和消耗多个kafka主题

根据春季云流文档： Accordidng到文档：

destination

The target destination of a channel on the bound middleware (e.g., the RabbitMQ exchange or Kafka topic). If the channel is bound as a consumer, it could be bound to multiple destinations and the destination names can be specified as comma separated String values. If not set, the channel name is used instead. The default value of this > property cannot be overridden.

但是，使用下一个配置，我已后：

spring: 
    cloud: 
    stream: 
     bindings: 
     testchannel: 
      group: test 
      destination: platform.metrics, platform.sleuth

，现在我有一个错误：

Caused by: java.lang.IllegalArgumentException: Topic name can only have ASCII alphanumerics, '.', '_' and '-' 
    at org.springframework.cloud.stream.binder.kafka.utils.KafkaTopicUtils.validateTopicName(KafkaTopicUtils.java:39) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RELEASE.jar:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:107) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RELEASE.jar:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:60) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RELEASE.jar:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:110) ~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE] 
    ... 20 common frames omitted

如何将多个主题绑定到一个@StreamListner或生成主题列表中的动态流式监听器？

来源

2017-06-18 Kirill Tolkachev

[相关小胶质讨论]（https://gitter.im/spring-cloud/spring -cloud流？在= 59465604f6a78eab485d7b25）。 –

你只需要更换逗号和下一个目的地值之间的空间，它会看起来像：

spring: 
    cloud: 
     stream: 
      bindings: 
       testchannel: 
        group: test 
        destination: platform.metrics,platform.sleuth

来源

2017-09-25 20:05:23

春云流和消耗多个kafka主题

回答

相关问题