Всем привет! Имеется тестовый кластер из трёх нод, работающих в докер-контейнерах. Так получилось, что пришлось остановить две ноды и зачистить там контейнеры. После восстанов...
Всем привет! Имеется кластер с 5 нодами. Хочу протестировать поведение в случае отказа части нод. Отключаю две (чтобы количество зукиперов было не чётным). В итоге кластеру ...
всем привет! вопросы по kafka-connect. Возможно ли для source коннектора ограничить, сколько сообщений он может вычитать и отрпавить за раз? batch.max.rows=10 не работает - п...
Всем привет! Вопрос по kafka-connect. Ни у кого в последнее время не возникало ошибки с трансформами, загружаемыми с confluent-hub: org.apache.kafka.common.config.ConfigExcept...
Всем привет! Столкнулся с проблемой при вычитке данных из view в БД Oracle с помощью source jdbc коннектора kafka-connect. Вьюха собирается с помощью пакета. При измненеиях в ...
Всем привет! Сталкивался кто-нибудь с такой ошибкой? Консьюмер читает данные из Кафки (версия 6.0 от confluent). Время от времени возникают такие ошибки: Error sending fetch r...
а кто-нибудь в kafka-connect транформировал строку в json? в строке лежит json с экранированными кавычками, нужно сделать из него json и применить фильтр
Всем привет! Вопрос с SSL. Есть консьюмеры на джаве и питоне, которые стучатся на порт с ssl шифрованием. Если в конфигах консьюмера задан сертификат - всё ок. Но если убрать ...
Всем привет! У кого-нибудь есть опыт с навешиванием acl на транзакции? Возникает ошибка " Transactional Id authorization failed: Transactional Id authorization failed.". Навес...