Я так и не разобрался что это. Это ж экосистема

Не) тут все понравилось, просто из того что надо было объединить из необъединяемого. Т.е в ksql для джоинов должны быть общие ключи, должна быть согласованность типов. Kslq мощная штука, если ещё заюзать ksql connect embedded, то ты можешь даже из бд пушить стрим т.е создавать топик, то тебе не нужно будет создавать какого нибудь демона в самом коде для чека БД. В данном случае если тебе нужно создать Outbox и при добавлении какой то записи за тебя это сделает Ksql connect на базе kafka connect не нужно для этого Outbox тебе пилить в коде паблишь и чекать бд. А там по тому чего хотели ребята из своих потребностей это избавиться от лишнего создания сервиса из набора данных которые поступали из стороннего ресурса с разными полями и неймингом в Ksql нужно строго соблюдать типы приходящих сообщений для того что бы создать промежуточный стрим и из промежуточного стрима уже пушить топик, так там как я посчитал этих стримов слишком много получилось бы и при разных ключах некоторые данные тупо просто терялись бы. В итоге возложить сервис на работу kafka и ksql не получилось)

0

18.11.2023

Sergey P · Accepted Answer

оно коннектится к кафке и позволяет тебе стримы описывать как источники данных, а потом делать всякие джойны и по сути SQL-ем трансформации делать. Потом ты можешь так же класть результат в новый стрим и оттуда кафка коннектом например в реальную базу

212 похожих чатов

Я так и не разобрался что это. Это ж экосистема

8 ответов

Похожие вопросы