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 на плюсах?