AS
например на эту тему были доклады
Виктор Гамов, Confluent - Kafka Streams IQ: «Зачем нам база данных?» - jug.msk.ru - 08/05/2019 - ч.1-2
Виктор Гамов, Confluent - Kafka Streams IQ: «Зачем нам база данных?» - jug.msk.ru - 08/05/2019 - ч.1-2
Size: a a a
2020 April 08
AS
там намного подробней объясняется
A
@gamussa похоже это все-таки не был комплимент :D
VG
@gamussa похоже это все-таки не был комплимент :D
AS
не знаю зачем думать по англ если умеешь по-русски
чем это лучше?
чем это лучше?
AU
похоже на вброос)
AS
да
AS
понятно
AS
мне чтобы понять надо пожить там
KA
Well, я как бы в омерице с 2010го, мозг сам собой перестроился
Но я поддержу. Даже когда не знал, кто слушал и сразу понимал, что русский. И слушать проще)
AS
🤟
VG
https://www.meetup.com/Apache-Kafka-NYC/events/269673016/ Live from New York!
神
Всем привет. Вопрос про Ksql-server. Есть абстрактный топик my_test. Задача - построить ktable с количеством записей по дням, опираясь на ROWTIME. Для этого пришлось сделать:
1)Create stream s_my_test with (kafka_topic='my_test', value_format='avro') ;
2)Create stream s_my_test_dt with (value_format='avro') as select timestamptostring(ROWTIME, 'yyy-MM-dd') as dt from s_mon_test;
3)create table t_my_test_dt as select dt, count(*) as cnt from s_my_test_dt group by dt;
В связи с этим два вопроса:
1) можно как-то в пункт 3 прийти покороче, без 1,2?
3)почему запрос select cnt, dt from t_my_test_dt; выводит мне вместо одной последней записи целую портянку строк, с cnt=n+1, даже при отсутствии записи в исходный топик?
1)Create stream s_my_test with (kafka_topic='my_test', value_format='avro') ;
2)Create stream s_my_test_dt with (value_format='avro') as select timestamptostring(ROWTIME, 'yyy-MM-dd') as dt from s_mon_test;
3)create table t_my_test_dt as select dt, count(*) as cnt from s_my_test_dt group by dt;
В связи с этим два вопроса:
1) можно как-то в пункт 3 прийти покороче, без 1,2?
3)почему запрос select cnt, dt from t_my_test_dt; выводит мне вместо одной последней записи целую портянку строк, с cnt=n+1, даже при отсутствии записи в исходный топик?
VG
神風
Всем привет. Вопрос про Ksql-server. Есть абстрактный топик my_test. Задача - построить ktable с количеством записей по дням, опираясь на ROWTIME. Для этого пришлось сделать:
1)Create stream s_my_test with (kafka_topic='my_test', value_format='avro') ;
2)Create stream s_my_test_dt with (value_format='avro') as select timestamptostring(ROWTIME, 'yyy-MM-dd') as dt from s_mon_test;
3)create table t_my_test_dt as select dt, count(*) as cnt from s_my_test_dt group by dt;
В связи с этим два вопроса:
1) можно как-то в пункт 3 прийти покороче, без 1,2?
3)почему запрос select cnt, dt from t_my_test_dt; выводит мне вместо одной последней записи целую портянку строк, с cnt=n+1, даже при отсутствии записи в исходный топик?
1)Create stream s_my_test with (kafka_topic='my_test', value_format='avro') ;
2)Create stream s_my_test_dt with (value_format='avro') as select timestamptostring(ROWTIME, 'yyy-MM-dd') as dt from s_mon_test;
3)create table t_my_test_dt as select dt, count(*) as cnt from s_my_test_dt group by dt;
В связи с этим два вопроса:
1) можно как-то в пункт 3 прийти покороче, без 1,2?
3)почему запрос select cnt, dt from t_my_test_dt; выводит мне вместо одной последней записи целую портянку строк, с cnt=n+1, даже при отсутствии записи в исходный топик?
а какая версия?
神
В 5.0.1 в железе вроде работает предсказуемо.