Spring Cloud Stream Processor от двух разных брокеров Kafka

Question

Я хотел бы знать, возможно ли связывать два разных брокера Kafka для ввода и вывода в Spring Cloud Stream.

Другими словами, я бы хотел, чтобы мой поток слушал в одном брокере Kafka и записывал вывод в другом брокере Kafka.

@StreamListener(Processor.INPUT)
@SendTo(Processor.OUTPUT)
public Object handle(String message) {
    // Processor.INPUTbeing bind to one Kafka broker
    // Processor.OUTPUT being bind to another Kafka broker
    // Write the logic here
}

Answer 1

Да, очень, вы можете! Вот мультисвязывающее приложение , которое читает и записывает в 2 различных кластера Kafka.

Обратите внимание на настройки связывания и привязки каналов в application.yml .