如何使用 spring boot 应用程序处理多个 kafka 主题？

Question

我正在使用 spring 引导应用程序实施 RestFul api。根据请求者，我需要选择主题并从该主题中获取数据。 假设如果我点击 url requester1/data 那么我应该从 topic1 获取数据，如果我点击 url requester2/data 那么我应该从 topic2 获取数据等等。

那么如何在 spring 启动应用程序中处理这些多个主题并在收到请求时从特定主题获取数据？

Answer 1

嗯。您应该将 ConsumerFactory<?, ?> 注入您的 RESTFull 服务并直接使用 KafkaConsumer API。

Spring Kafka 中的任何现有 KafkaMessageListenerContainer 架构都是长期存在的事件驱动程序实现，无法在运行时进行调整以执行按需消费。这正是 KafkaConsumer 存在的原因。