不同的配置两个弹簧卡夫卡消费者在一个应用程序

Question

我是新手卡夫卡。我正在研究Spring-Kafka POC。我们的KAFKA服务器已被Kerberized化。通过所有必需的配置，我们可以访问Kerberized Kafka服务器。现在我们有另一个要求，即必须从非Kerberized（简单Kafka Consumer）Kafka服务器消费主题。我们可以在单个应用程序中通过创建另一个拥有自己的侦听器的KafkaConsumer来做到这一点吗？

Answer 1

是;为第二个消费者定义一个不同的消费者工厂bean。

如果你使用Spring Boot的自动配置，则必须手动声明一方面是因为如果一个用户定义的bean被发现的自动配置被禁用。