Как настроить несколько потребителей kafka в файле application.yml

Question

На самом деле у меня есть микросервис на основе Springboot, и я использовал kafka для получения / получения данных из другой системы. Теперь мой вопрос: у меня есть две разные темы, и на основе тем у меня есть два разных потребительских класса для потребления данных,

как определить несколько свойств потребителя в application.yml файле?

Я настроил для одного потребителя в application.yml, как показано ниже: -

spring:
    kafka:
         consumer:
            bootstrapservers: http://199.968.98.101:9092
            group-id: groupid-QA-02
            auto-offset-reset: latest
            key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
            value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

Я использую @KafkaListener в своих потребительских классах

пример потребительского метода, который я использовал в коде @KafkaListener (themes = "$ {app.topic.b2b_tf_ta_req}", groupId = "$ {app.topic.groupoId}") public void потребление (строковое сообщение) создает исключение {

}

Answer 1

Насколько я знаю, bootstrap-серверы принимают список серверов через запятую т.е. если вы установите его на server1: 9092, server2: 9092 kafka должен подключиться ко всем из них