不同的配置兩個彈簧卡夫卡消費者在一個應用程序

Question

我是新手卡夫卡。我正在研究Spring-Kafka POC。我們的KAFKA服務器已被Kerberized化。通過所有必需的配置，我們可以訪問Kerberized Kafka服務器。現在我們有另一個要求，即必須從非Kerberized（簡單Kafka Consumer）Kafka服務器消費主題。我們可以在單個應用程序中通過創建另一個擁有自己的偵聽器的KafkaConsumer來做到這一點嗎？

Answer 1

是;爲第二個消費者定義一個不同的消費者工廠bean。

如果你使用Spring Boot的自動配置，則必須手動聲明一方面是因爲如果一個用戶定義的bean被發現的自動配置被禁用。