Confluent Cloud does not support Single Message Transformations (SMTs).". Наш кейс - писать из разных топиков в один ElasticSearch индекс через sink, апсертами разных частей документа. В self managed kafka connect мы делаем это при помощи RegexRouter SMT. Может кто-то знает есть ли какой-то другой вариант для confluent cloud?
Можно наверное сделать что-то с помощью ksqlDB
Имеешь в виду создать коннектор с помощью ksqlDB? Или что-то другое?
Не написать процедуру с помощью ksqlDB
Обсуждают сегодня