我是Kafka的新手。我正在做一个SpringKafkapoc。我们的Kafka服务器被烧焦了。通过所有必需的配置，我们可以访问KerberizedKafka服务器。现在我们有了另一个需求，我们必须从非kerberized（简单的kafka消费者）kafka服务器消费主题。我们可以在单个应用程序中通过创建另一个kafkaconsumer和它自己的侦听器来实现这一点吗？
我是Kafka的新手。我正在做一个SpringKafkapoc。我们的Kafka服务器被烧焦了。通过所有必需的配置，我们可以访问KerberizedKafka服务器。现在我们有了另一个需求，我们必须从非kerberized（简单的kafka消费者）kafka服务器消费主题。我们可以在单个应用程序中通过创建另一个kafkaconsumer和它自己的侦听器来实现这一点吗？
1条答案
按热度按时间cuxqih211#
对；只需为第二个消费者定义一个不同的消费者工厂bean。
如果您使用的是springboot的自动配置，那么您将不得不手动声明这两者，因为如果发现了用户定义的bean，自动配置将被禁用。