我想配置一个将绑定到多个主题的消费者应用程序（将在一个JVM上运行） .
消费者应用程序中的每个"consume"（假设我有2个要监听的主题）方法都将使用@StreamListener注释进行设置，并将链接到特定主题 .
此外，我将在不同的消费者组中配置每个消费者 .
spring.cloud.stream.bindings.<consumer>.group=<group name>
我们的想法是使用来自少数主题的消息，让我们假设所有具有相同优先级的消息，操纵它们并将它们传递给相关的微服务 .
消费者应用程序在这种配置中的表现如何？
消息将逐一传来？
我需要在不同的线程中实现每个列表器吗？
这种方法是否很好？
Kafka版本0.8.2.1（spotify image）
Spring-cloud-stram Brixton.RELEASE
谢谢 .
1 回答
在Brixton发行版中，每个@StreamListener方法都将使用来自不同线程的消息（您将看到线程：来自KafkaMessageListenerContainer的FetchTask用于每个绑定） . 因此，消息消耗在这些线程之间，对应于消费来自各个主题的消息 .