5405 вопросов по kafka

Всем привет Есть у кого опыт использования MirrorMaker2 с переливом оффетов? Я делаю сейчас на своих кластерах и он чушь какую-то переливает.

Ребята, я тут уже обгуглился) может кто решал подобную задачу (кажется типичной) и сможет подсказать. Дано - aws msk, уже вовсю пару лет в продакшене, нет ни авторизации, ни ...

Привет, у меня вопрос к экспертам :) Кафка старая 2.0.0 при добавлении нового сервера не меняли настройки для репликации __consumer_offsets топика (системного) но при апдейт...

А можно подробнее о платных фичах?

А при unclean.leader.election.enable=true если лидер пропал, то оставшиеся реплики (которые не insync) никак не смогут проголосовать и выбрать нового лидера самостоятельно? На...

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

кто нибудь имел такую ошибку [2023-07-21 09:37:56,442] WARN [SocketServer listenerType=ZK_BROKER, nodeId=3] Unexpected error from /172.18.0.1; closing connection (org.apache.k...

Приветствую. Пускаю 3 KRaft брокера на localhost. config/kraft/server0.properties: node.id=1 controller.quorum.voters=1@localhost:9093,2@localhost:9095,3@localhost:9097 liste...

Коллеги, приветствую. В кафке новичок, поэтому заранее прошу прощения за возможно глупые вопросы. Есть интеграционные тесты на питоне, при их запуске поднимается kafka(3.2.3-d...

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

Братцы, а не работал ли кто с библиотекой fastkafka? Я создал свой consumes-метод: @kafka_app.consumes(topic="example_topic", auto_offset_reset="earliest", enable_auto_c...

Всем привет! А кто-нибудь имел опыт обновления Kafka с 2.Х.Х версий до 3.Х.Х или выше, какие шаги в целом, меняются ли конфиги как то сильно? Или просто гасим и ставим новую в...

Тут возникла странная ситуация с кафкой... Уже кучу метрик вывел на графики - видно проблемы, но корневую причину не могу найти. История такая - всё работает прекрасно, продюс...

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

Братцы, нужны советы мудрые. Решил я развернуть у себя на локальном хосту отладочкую Кафку. Чтобы на ней тестировать своё приложение. Взял я docker-compose.yaml от bitnami. ...

что значит идемпотентно? exactly once? а как разрулить кейс, когда транзакция в БД прошла, в запись в кафку упала с ошибкой? (о чем Гари и пишет)

что значит "приоритет у топиков" ?)

Привет! В наследство достался кластер kafka c zookeeper ,версия 3.2.0, 3 ноды. Стоит задача разово среплицировать с него данные в новый кластер,но уже с kraft. С kafka пра...

Привет! Есть kafka streams приложение, которое читает 3 топика и сохраняет значения в local state (+ каждый local state сохраняет свое состояние в changelog топик). У всех то...

Скажите зачем люди используют авс лямбды, вместо того что бы создавать отдельные консьюмеры в кафке ? К примеру у нас стоит лве ec2 Kafka, мы за нее платим, но почему то у нас...