Andrey

Скажите, а какие вы docker image'ы используете например что бы поднять schema registry? У меня следующий usecase, есть aws ECS работающий через Fargate (амазоновский аналог do...

Понял, тогда укажу какие то очевидные вещи по которым групировки или where будет идти, вопрос можно ли потом поменять в ходе работы?

Скажите, а при создании таблицы есть ли смысл указывать ORDER BY если потом в селектах ORDER BY нет?

Пытаюсь сделать CREATE DATABASE exchange ON CLUSTER pushex; Исполнение команды висит пока не вылетает по таймауту. В логах всё что показывает: 2020.11.02 11:21:27.035483 [ 15...

А сколько нужно для kafka engine партиций создавать у топика? У меня 30 партиций и кх кластер из 4ёх нод, почему-то они между собой делить партиции не хотят, одна нода берёт в...

Делаю drop table, потом снова пытаюсь ту же таблицу создать - говорит ошибка. Poco::Exception. Code: 1000, e.code() = 2, e.displayText() = File not found: /mnt/cold/clickhouse...

А количество тасков можно изменить после создания? А то читаю доку, пишут: The assignment of partitions to tasks never changes; Получается если у меня было tasks.max=2 то есл...

Каким образом можно прокинуть параметр вьюшке при инициализации сервера? Как пример def retrieve_tasks(db, cid): где db это connection pool инициализированный при старте прило...

а есть пример? Я тут смотрю функции работы с JSON'ом и не могу понять как мне задать шаблон по которому парсить этот объект?

Подскажите пожалуйста, кто какой docker image использует для kafka schema registry? Я вижу что популярным является https://hub.docker.com/r/confluentinc/cp-schema-registry но ...

Подскажите, а что бы воспользоваться вот этим коннектором https://docs.confluent.io/kafka-connect-s3-sink/current/index.html#install-the-amazon-s3-sink-connector мне нужна как...

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

А сколько места занимает поле String если не указывать FixedString? Столько сколько значение занимает + int64 для указателя на это значение?

Каким образом можно сделать динамический таймаут который меняется в рантайме? Задача выглядит примерно так: есть блокирующая функция которая читает из канала, если канал не от...

Настраиваю репликацию, не могу понять почему у меня обе ноды показывают как лидер таблицы. Может я что то не в том порядке сделал? https://dumpz.org/cQdFSh6f8KZc

Уже :) Кстати, а confluent не занимается реализацией kafka streams фреймворка на других языках? А если конкретно то на Go?

А можно ли что бы kafka engine брал json не из рутового объекта, а из внутреннего? например у меня в кафке сообщение: {"transaction_id": "xxx", "payload": {SOME_JSON_FOR_CLICK...

Скажите, а есть ли кто в Кассандре разбирается? Может у кассандры свой телеграм канал есть (не могу найти)

А есть какая нибудь рабочая альтернатива кафке, но что бы не была написана на java?

Вот например у меня minikube, я взял сделал kubectl delete pod --all -n kube-system А оно всё заново подняло автоматически. По идее заново должны то поднять controller-manager...