IT
есть ещё атрибут броеера
Size: a a a
2020 December 09
IT
работает как дефалт партищен намбер если не указано при создании
IT
видимо придется страдать или баш скрипт написать
IT
какая-то странная реклама
IK
Привет, направте плиз, запустил ksqldb, прошел туториал, но никак не могу найти ответ.
Если я сторю ktable то в теории я получаю таблицу лайк sql в памяти, которая изменяется из стрима.
но в реальности вижу, что при SELECT * FROM riderLocationstable EMIT CHANGES; как-то долго думает, вроде как перечитывает топик, может чего не доделал и она не формируется, а просто работает в виде стрима? или как просто вывести сформированную таблицу полностью? на подобие select * from TABLE;
Если я сторю ktable то в теории я получаю таблицу лайк sql в памяти, которая изменяется из стрима.
но в реальности вижу, что при SELECT * FROM riderLocationstable EMIT CHANGES; как-то долго думает, вроде как перечитывает топик, может чего не доделал и она не формируется, а просто работает в виде стрима? или как просто вывести сформированную таблицу полностью? на подобие select * from TABLE;
VG
Igor K
Привет, направте плиз, запустил ksqldb, прошел туториал, но никак не могу найти ответ.
Если я сторю ktable то в теории я получаю таблицу лайк sql в памяти, которая изменяется из стрима.
но в реальности вижу, что при SELECT * FROM riderLocationstable EMIT CHANGES; как-то долго думает, вроде как перечитывает топик, может чего не доделал и она не формируется, а просто работает в виде стрима? или как просто вывести сформированную таблицу полностью? на подобие select * from TABLE;
Если я сторю ktable то в теории я получаю таблицу лайк sql в памяти, которая изменяется из стрима.
но в реальности вижу, что при SELECT * FROM riderLocationstable EMIT CHANGES; как-то долго думает, вроде как перечитывает топик, может чего не доделал и она не формируется, а просто работает в виде стрима? или как просто вывести сформированную таблицу полностью? на подобие select * from TABLE;
Emit changes сидит и ждёт пока новые сообщения придут. Если тебе просто как в SQL table смотри в сторону pull queries
IK
Спасибо!
IK
А у ksqldb при формировании таблицы есть возможность retirement time для строки? после которой могло удалится значение/строка или это не та история и так нельзя(нужно ин мемори с терайрентом, но не хочу редис 😊 )
IK
Ещё раз спасибо!
SP
а что значит "все еще"? есть другие варианты ?
E
Судя по дискуссии в нашем уютном чатике про event-driven системы и как лучше моделировать события / сообщения, не все еще успели почитать отличную книгу Бена Стопфорда про построение таких систем.
Бен представляет сначала концептуальный материал, потом показывает как можно использовать Kafka Streams и KSQL для постоения вот таких систем.
Держите книгу (без смс)!
Кстати, на сайте конфлюента лежат книги по Кафке и обработке стримов, а не все про это знают!
Ловите тоже (там надо оставить email)!
Бен представляет сначала концептуальный материал, потом показывает как можно использовать Kafka Streams и KSQL для постоения вот таких систем.
Держите книгу (без смс)!
Кстати, на сайте конфлюента лежат книги по Кафке и обработке стримов, а не все про это знают!
Ловите тоже (там надо оставить email)!
Пардон за ап... Случайно ни у кого не завалялась выше упоминаемая книга Стопфорда «Проектирование событийно-ориентированных систем» на русском?
IK
тут наверно, только если на компакт завязаться и на уровне приложения обнулять, как гипотиза
и вот я про компакт не до конца понял, и кто даст пояснение, у него тоже есть ретеншн? вроде если ретеншн месяц и за это время ключ не изменился, то сообщение промаркируется как deleted? и в итоге удалится из сегмента
и вот я про компакт не до конца понял, и кто даст пояснение, у него тоже есть ретеншн? вроде если ретеншн месяц и за это время ключ не изменился, то сообщение промаркируется как deleted? и в итоге удалится из сегмента
2020 December 10
IT
@gamussa может дашь инсайд, планируется ли kafka-streams lib для non jvm языков? (видел какой-то кустарный проект только для шарпов)
IT
просто вроди как librdkafka почти под все языки есть