Zwei spring kafka verbraucher mit unterschiedlicher konfiguration in einer anwendung

Question

ich bin neuling zu Kafka. Ich arbeite an einem Spring-Kafka POC. Unsere KAFKA-Server sind kerberisiert. Mit allen erforderlichen Konfigurationen können wir auf den kerberisierten Kafka-Server zugreifen. Jetzt haben wir eine weitere Anforderung, wo wir Themen von nicht-Kerberized (einfacher Kafka Consumer) Kafka-Server konsumieren müssen. Können wir dies in einer einzigen Anwendung tun, indem wir einen anderen KafkaConsumer mit einem eigenen Listener erstellen?

Answer 1

Ja; Definieren Sie einfach eine andere Consumer Factory Bean für den zweiten Konsumenten.

Wenn Sie die automatische Konfiguration von Spring Boot verwenden, müssen Sie beide manuell deklarieren, da die automatische Konfiguration deaktiviert ist, wenn eine benutzerdefinierte Bean erkannt wird.