Вячеслав

А, то есть лидер "жив", но диск мёртв при этом? А 4 ноды как спасает? Что-то мне кажется там вообще не в кворуме дело. Так-то трёхнодовая кафка с 1-2 Тб данных нормально пер...

Справедливости ради, CEF действительно небольшие должны быть: https://docs.elastic.co/en/integrations/cef Но совсем необязательно совпадающие по размеру с сетевыми пакетами, ...

Требуется пояснительная бригада - а в чём разница? Какой контекст? Если холивар ради холивара - монетку киньте. :)

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

Просто в общем случае даже "потому что могу" не срабоатет - брокеров-то может быть больше одного в кластере и сетевых соединений будет в любом случае много - до каждого. Так п...

Большинство, я бы сказал. А дебаг эласталерта что-нибудь говорит? Я мало его трогал, но в целом синтаксис не выглядит знакомым. По крайней мере, type=elasticsearch - это касто...

И в чём конкретно проблема с этим? Если включена аутентификация, можете хоть через kafka-acls собирать, хоть какой-то гуи-тулзой.

А в партициях-то сообщений поровну?

Ну вот у нас в похожей ситуации как раз дампы раз в сутки перекладываются. Кафка там вообще не особо ложится. Это всё-таки поток небольших сообщений, а не огромные отдельные ...

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

А вы зачем так делаете? Почему не использовать предусмотренные механизмы логгирования вместо удаления гланд через непредназначенное место?

kowl вы запускаете ровно там же, где и питон? И там тоже адрес указан как kafka:32575 ?

В контролируемой инфре это решается добавлением своего домена в серты всем брокерам и раунд-робин днс, а вот в вашем случае хз даже. Точно нет возможности там свой домен подки...

Т.е. оно на лету будет подменять адреса брокеров? UPD: А, вижу, не будет. > The kafka_broker filter is experimental and is currently under active development. Ну и > The Ka...

Ну там отдельное приложение sigma-streams-ui в репо. Я ничего этого не щупал, но не знаю, почему бы не попробовать? Компоуз приложен, по идее, стартануть всё это и посмотреть ...

А там именно приложение с мультитенанси, а не сама кафка? Т.е. структура вся одинаковая, только сообщения разным юзерам "принадлежат"? И что с приложениями - продюсерами/консю...

curl -skv telnet://<broker address>:<broker port> с той же машины, на которой запускается кафкатул что говорит?

С поиском среди всех сообщений в топике для каждого юзера триллиард в секунду-то вряд ли выйдет. Или речь о том, что консьюмер просто будет "потреблять" топик и игнорить всё,...

Критичность - это про важность данных. Вам критично, если кластер на ходу развалится и потеряет данные? В некоторых случаях это не проблема, потому что это легко замечается и ...

Это типа ((поле1 ИЛИ поле2 ИЛИ поле3) И поле4), или вот чтобы именно «после»?