VladMl

Кафка в кубике установлена из через Confluent Helm по доке от Confluent. Наблюдается стабильное падение зукипера через несколько дней после установки, активного использования ...

Есть ли какие-нибудь паттерны для обработки такой ситуации в Kafka Streams: KStream - KTable join. Из стрима приходит месадж который должен заэнричится данными из KTable но в ...

как у сборки confluent изменить server.properties? Меняю тут etc/kafka/server.properties но в CONFLUENT_CURRENT есть только confluent.cLotZbBy/kafka/kafka.properties который...

Есть кейс KStream application, Topic 1 - 1 partition, Topic 2 - 3 partitions. Для джоина кол-во партиций должно быть одинаковым. Есть ли способ сделать репартишн Topic 1 чтобы...

С KSQL кто-то работал? Select * from ktable возвращает только часть данных, хотя в исходном топике все данные есть. Такое было и в предыдущих версиях, думал баг, но в 5 релизе...

Хочу для записи паркета использовать HDFS Sink connector но есть вопросик. Что будет если rotate.interval.ms=60000 но за это время не прийдет ни одного месаджа, будут создава...

"Мои тесты показали, что, используя клиент rdKafka и рубая его жескто через SIGKILL можно получить дыры в данных. Даже если rdKafka ограничить всего 1-м сообщением во внутренн...

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

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

у кого есть опыт интеграции какфки с rule engine и какими?

А можно подробнее, почему разочаровались в event-driven и возненавидели кафку?

А трейс включить и посмотреть в логах что когда коммитит?

А разве mapr это не Hadoop на плюсах?