A
Size: a a a
2021 January 15
AP
Всем привет
у меня есть приложение на kafka-streams, метрики собираю prometheus’ом
может, подскажет кто-то, можно ли отслеживать рейт записи по каждой конкретной партиции?
у меня есть приложение на kafka-streams, метрики собираю prometheus’ом
может, подскажет кто-то, можно ли отслеживать рейт записи по каждой конкретной партиции?
2021 January 16
YK
Приветствую! На сколько хорошая идея использовать много pull queries к ksqldb?
YK
То есть, я планирую вместо запросов к реляционной базе, делать pull запросы к ksqldb в определенных, достаточно частых кейсах
YK
Реже. Максимум пару десятков в секунду
YK
На сколько вообще это хорошее решение и масштабируемое
VG
Всем привет
у меня есть приложение на kafka-streams, метрики собираю prometheus’ом
может, подскажет кто-то, можно ли отслеживать рейт записи по каждой конкретной партиции?
у меня есть приложение на kafka-streams, метрики собираю prometheus’ом
может, подскажет кто-то, можно ли отслеживать рейт записи по каждой конкретной партиции?
Знаю что можно по таскам но один таск может обрабатывать несколько партиций
VG
Приветствую! На сколько хорошая идея использовать много pull queries к ksqldb?
Норм
YK
Понял, гуд. А не подскажете, вдруг, когда новый ksqldb-server 0.14, завезут в конфлюент сборку cp-ksqldb-server? 🙂
VG
Понял, гуд. А не подскажете, вдруг, когда новый ksqldb-server 0.14, завезут в конфлюент сборку cp-ksqldb-server? 🙂
Наверное уже в 6.1 (туда же и ak 2.7 должны завезти)
VO
Всем привет! Есть ли у кого опыт настройки Debezium source коннектора для MS SQL? Debezium воспринимает типы datetime и datetime2, которые сами по себе не содержат timezone, как UTC. В jdbc source коннекторе можно указать db.timezone, для Debezium ничего подобного не нашел. Правильно ли я понимаю, что единственный выход делать custom SMT? Может быть кто-нибудь встречал подобные трансформации?
AI
Всем привет! Есть ли у кого опыт настройки Debezium source коннектора для MS SQL? Debezium воспринимает типы datetime и datetime2, которые сами по себе не содержат timezone, как UTC. В jdbc source коннекторе можно указать db.timezone, для Debezium ничего подобного не нашел. Правильно ли я понимаю, что единственный выход делать custom SMT? Может быть кто-нибудь встречал подобные трансформации?
Привет! Делали для такого конвертер https://debezium.io/documentation/reference/development/converters.html
AI
Если интересно, код могу пошарить попозже
AD
нашел вроде https://kafka.js.org
N
ну это через прослойку nodejs как бэкэнд получается: js -> websocket -> nodejs <- kafkaconsumer
так ведь https://kafka.js.org тоже зависит от nodejs
