Denis Vlasov

Доброго времени суток, кто-нибудь сталкивался с такой проблемой? В какой то момент консьюмер перестает читать сообщения, лаг накапливается. При этом нет ошибок консьюмера ни в...

Коллеги, подскажите я правильно понял? log.retention.bytes - максимальный размер лога ВСЕЙ Кафка. retention.bytes - максимальный размер 1 партиции. Допольнительно: Есть ли сп...

Коллеги! Подскажите куда копать? На клиенте получаю ошибку: "[AdminClient clientId=adminclient-1] Failed authentication with server/ip (Authentication failed during authentic...

Коллеги! Кто нибудь поддерживает актуальную java под кафкой? Столкнулись с проблемой керберос авторизации?

Коллеги, подскажите: Один продюсер пишет в топик с 3 партициями. Запущены два консюмера в двух подах под одним group-id. Проверили - читаются только партиции 0 и 1. Данные и...

нескромный вопрос, может кто в курсе. Почему у зукипера и кафки есть стоп.sh, а у миррормейкера и кафкаконнекта нету? В этом какой то сакральный смысл кроется?

Коллеги, вчера керберизированная кафка сломалась(сама по себе). Снапшоты вернул на два дня назад и все равно не работает. Ошибка: "javax.security.sasl.SaslException: Error in ...

Коллеги, я уже писал выше что часто ловим странные варнинги, которые влияют на данные(потеря до 30%). Сейчас выловил первый, с которого все начинается: "java.io.IOException: C...

Коллеги, возникла потребность передавать данные из одной кафка в другую as is. Знаю решение через mm2 с фильтром по топикам. Вроде как можно через filestream connector. Есть е...

Подскажите куда копать? Пропали Consumer группы у топика. AKHQ говорит что нет никаких групп, хотя этот топик точно читался AKHQ и CMAK показывают группы тех кто СЕЙЧАС читае...

Коллеги! Можно тут кинуть клич на поиск кандидата на работу? Прошу не банить сразу, если нельзя - буду молчать :)

Коллеги, кто-нибудь пользуется библиотекой python - pykafka? Не пойму как с этой библиотекой подключатся к Кафка. В методе KafkaClient есть hosts, но нет ни механизма, ни прот...

Коллеги, всем привет! Как понять какая версия MirrorMaker используется в 2.8.0? В bin/ есть connect-mirror-maker.sh и kafka-mirror-maker.sh и при вызове —version выдает версию...

Коллеги, заметил проблему с Зуукипером. Согласно JMX метрикам служба рестартовала, но по линуксу служба работает нормально, без рестартов. С чем это может быть связано?

Коллеги, подскажите пож-та. Есть ли какое-нибудь решение для вот такой задачи: Собирать в ELK инфо из топиков <key> <datetime> <key> - это соответственно key из сообщения <dat...

Кто-нибудь может помочь с аутентификацией java приложения через керберос? 1. Windows 10 2. Java-приложение 3. Запуск: ./java.exe "-Djava.security.krb5.conf=c:\krb5.ini" "-Dmic...

Всем привет! Подскажите направление(только не в гугл, был там) Есть два кластера. Настроен ММ2(актив-актив). В таком формате у меня 4 топика: cluster_1.topic, cluster_1.A.to...

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

Коллеги, кто нибудь тестировал retention.bytes? Есть неявные проблемы с этой настройкой?

Вот и вопрос, я один такой мимокрокодил? Или еще кто словил?