在一个应用程序中具有不同配置的两个 spring kafka 消费者

Question

我是卡夫卡的新手。我正在研究 Spring-Kafka POC。我们的 KAFKA 服务器是 Kerberized。通过所有必需的配置，我们能够访问 Kerberized Kafka 服务器。现在我们有另一个要求，我们必须使用来自非 Kerberized（简单 Kafka 消费者）Kafka 服务器的主题。我们可以通过创建另一个具有自己的侦听器的 KafkaConsumer 在单个应用程序中执行此操作吗？

Answer 1

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

如果您使用 Spring Boot 的自动配置，则必须手动声明两者，因为如果发现用户定义的 bean，自动配置将被禁用。