Aleksey Uzhva

Коллеги, вопрос может быть глупый, но подскажите плиз. Множество коннекторов может использовать общие status.storage.topic, config.storage.topic, offset.storage.topic ?

Привет! А как бы вы решали задачу следующего рода: * Есть 3 топика: A (KStream) -> B (KTable) -> C (KStream), между которыми проходит перетекание данных в этом порядке. На ...

А кто-то разбирался по нотариусам в Армении? Где-как? Надо доверенность с апостилем.

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

Господа, а как бы вы решили задачу, если к какому-то топику надо было бы подключить, скажем, 10к консюмеров в группе? Смущают две вещи: 1) Подключение-отключение консюмеров б...

Еще вопрос. Если на дев-стендах из-за большого кол-ва партишнов кафка потребляет значительные CPU ресурсы, то это как-то решаемо? Для продакшна это будет нормально и оправдано...

Скажите, а пропускают ли стримы больше одного сообщения по топологии одновременно? То есть оно всегда читает, доходит до конца топологии, и потом читает следующее? Или работ...

Ещё вопрос про железо:) Скажем, если бы вы проектировали что-то, что должно процессить объемы порядка 20-50k входящих сообщений в секунду. Сообщения мелкие, менее 2кб. Проход...

Друзья, а скажите что происходит если в процессе работы консьюмера или продюсера падает брокер нода, либо наоборот вводится в строй новая нода. Вызовет ли это оповещение кли...

А кафка коннект обязательно запускать шелл скриптом и туда сабмитить плагины? я могу его поднять как часть своего процесса?

А как вы экспоузите внутри-облачную кафку наружу? NodePort? LoadBalancer?

А что сейчас наиболее пристойно из CDC из оракла в кафку?

Вроде пилили улучшение для GlobalKTable что стрим не пойдёт процессить пока оно не наполнится. Но могу наврать. А есть ли такое? И есть ли подобное для KTable?

А кто-то в курсе деталей? Как там с авторизацией, какие политики балансировки, как это вообще прописывается на клиенте? Как нода брокера?

А у Кафки топик можно закрыть на запись? То есть чтоб записать туда ничего было нельзя но консьюмеры могли таки дочитать все что там уже есть

А есть идеи чем балансер выигрывает от нодпорта? В общем то поставить его не проблема. Однако хотелось бы понять.

А в более прикладном плане? СДК то у вас наверняка скомпилированный. То есть на клиенте схему там не меняют

Вопрос больше про то что клиенту придёт о том уведомление и он перебросит запросы куда надо?

А копия папки с коннект плагинами должна быть на каждом хосте где запущен connect-distributed, так?

По одному на ноду или один на всех? Трафика много (сотни мбит до гигабита на кластер)