我有一个用例，我想创建主题和它的消费者的需求，即，当我主持一个产品1销售它应该创建一个主题和消费者的产品1，如果我创建产品2它应该创建一个主题和消费者的产品2。
的数据
主题和消费者的创建应该是按需的，以便一个产品上的流量不应该影响其他产品。
我能够根据需要创建新的主题，并将新的任务推到该主题，并能够从同一个消费者读取它，我已经配置为使用模式从动态主题读取，但坚持在创建消费者专用于该新主题
任何人都可以请帮助我如何创建消费者在旅途中订阅一个主题？
我有一个用例，我想创建主题和它的消费者的需求，即，当我主持一个产品1销售它应该创建一个主题和消费者的产品1，如果我创建产品2它应该创建一个主题和消费者的产品2。
的数据
主题和消费者的创建应该是按需的，以便一个产品上的流量不应该影响其他产品。
我能够根据需要创建新的主题，并将新的任务推到该主题，并能够从同一个消费者读取它，我已经配置为使用模式从动态主题读取，但坚持在创建消费者专用于该新主题
任何人都可以请帮助我如何创建消费者在旅途中订阅一个主题？
1条答案
按热度按时间8ehkhllq1#
考虑到你最初用spring-kafka标记了这个问题（@OneCricketeer删除了标记;我把它加回去了），请参阅这个答案及其注解，以获得指向一堆答案的链接，这些答案展示了使用Spring动态添加消费者的几种技术。