Fedor

Ребят, раньше писал насчет проблемы с коннекторами. На всякий еще раз продублирую. Добавлял в рассылку кафки, ответа нету. Допускаю что это баг Source connectors stops workin...

Ребят. У меня вопрос есть. Кластер содержит несколько connect воркеров. Также имеется большое число различных коннекторов. Каждый коннектор должен иметь свою конфигурацию(пар...

Подскажите пожалуйста, после рестрта брокеров, стримы перестают работать и в логах пишут много таких сообщений. WARN o.a.k.c.NetworkClient [kafka-coordinator-heartbeat-thread...

Ребят, столкнулся с тупой ситуацией Коннект кластер на загружает джарник. При старте в логах пишет «INFO Loading plugin from моя папка» Дальше мертвая тишина около 2 минут П...

Ребят, привет. Есть вопрос. Ситауция следующая. Есть кафка кластер, есть кластер коннекторов. Коннекторы подтягивают данные с нескольких источников и пишут в один топик. Топи...

Коллеги привет. Озадачился таким вопросом. В sink коннекторе есть метод put(Collection<SinkRecord> records), через который передаются сообщения из кафки. Коммит оффсетов выпо...

Основная мотивация заключается в следующем. Экспортер собирает информацию по ошибочным логам из эластик стека. В связи с различными задержками время в прометеусе и реальное вр...

Интересная вещь получается. У меня вчера упал broker2, после чего его под рестартовал. Спустя 4 минуты в топик добавилось новое сообщение. Сейчас смотрю и вижу, что лидер парт...

Коллеги, привет. Столкнулся с проблемой, которая связана с коннекторами. Конфигурация: 3 брокера, 1 зукипер, 1 коннект воркер, 8 коннекторов(у большинства число тасок 10) При...

Всем привет. Я написал собственный sink connector. В sinkTask сообщения из топика приходят в виде объектов SinkRecord. Мне надо SinkRecord преобразовать в собственный объек...

У меня вопрос еще тогда. Есть небольшой пробел в понимании, поэтому есть небольшие сомнения. Через доки не особо понял. Принятие решение в какую партицию класть сообщение про...

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

Ребят, подскажите. Надо ошибочные логи из elastic стека передавать в прометеус, чтобы в дальнейшем в графане отображать появление этих ошибок. Есть простые пути?

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

Ребят, подскажите. Где sink connector хранит офсеты? Source хранит в connect-offsets

Так он же нормально стартует изначально и прекрасно работает. Если один раз смог законнектиться, то и в дальнейшем должен. Или я что то не догоняю? Щас попрошу чтобы проверили

Ребят, можете подсказать, поддерживается ли в Kafka Connect транзакционность?

Ребят, подскажите, а в коннекторах возможно использовать Avro?

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

Всем привет, подскажите пожалуйста, как можно использовать массив массивов [[1],[1,2,3],[2,3]] в качестве одной из нескольких feture для sklearn?