我正在使用spring启动应用程序实现restfulapi。基于请求者，我需要选择主题并从该主题获取数据。假设如果我点击url requester1/data，那么我应该从topic1获取数据，如果我点击url requester2/data，那么我应该从topic2获取数据，依此类推。
那么，如何在spring启动应用程序中处理这些多个主题，并在收到请求时从特定主题获取数据呢？
我正在使用spring启动应用程序实现restfulapi。基于请求者，我需要选择主题并从该主题获取数据。假设如果我点击url requester1/data，那么我应该从topic1获取数据，如果我点击url requester2/data，那么我应该从topic2获取数据，依此类推。
那么，如何在spring启动应用程序中处理这些多个主题，并在收到请求时从特定主题获取数据呢？
1条答案
按热度按时间yfjy0ee71#
好。你应该注射
ConsumerFactory<?, ?>进入restfull服务并使用KafkaConsumer直接使用api。任何现有的
KafkaMessageListenerContainerSpringKafka中的体系结构是长寿命的，事件驱动程序实现它不能在运行时进行调整以按需执行消费。那到底是为了什么KafkaConsumer存在。