брокера, трансформирует и помещает в другой (внутренний) брокер. Конфигурация поднимается, но стрим стучится в топик-out на внешнем брокере, а должен во внутреннем. По логам вижу, что внутреннего брокера AdminClient видит, но в ProducerConfig сервера внешнего брокера. Может есть у кого пример такой конфигурации?
Так нельзя. Kafka streams работают с одним кластером.
а как лучше работать в такой ситуации?Сделать мирроринг в другой кластер, а потом трансформации через kafka-streams в другом кластере?
Обсуждают сегодня