VG
Size: a a a
2020 April 09
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, даже при отсутствии записи в исходный топик?
Господи, вот уж привычка дурная с оракла прификсы делать для таблиц t_
神
Спасибо огромное! Спокойной ночи)
2020 April 10
ὦ
А нет какого-нибудь скрипта который схему отправлял в регистри? Чет не хочется руками экранировать большие схемы
М
Всем привет. Подсобите, пожалуйста.
kafka_2.11-0.9.0.0
jdk-11.0.6
При использовании команды:
получаю:
0.
kafka_2.11-0.9.0.0
jdk-11.0.6
При использовании команды:
bin/kafka-server-start.sh config/server.properties
получаю:
0.
003s][warning][gc] -Xloggc is deprecated. Will use -Xlog:gc:/Users/admin/Documents/Prog/kafka_2.11-0.9.0.0/bin/../logs/kafkaServer-gc.log instead.ак быть и как решать?
Unrecognized VM option 'PrintGCDateStamps'
Error: Could not create the Java Virtual Machine.
Error: A fatal exception has occurred. Program will exit.
К
A
NK
Коллеги, подскажите хороший UI для Kaffka
NK
смотретьсостояние кластера, менеджить топики