и еще вопрос по ретеншену. Стоял delete 20 дней.
Постаил только что 2 дня. Ожидаемый результат - кафка должна была удалить сообщения старые.
Реальный резульятат - ничего не удалило.
Как оно вообще запускает cleanup?

там есть еще параметр про интервал чистки

по умолчанию он равен получасу вроде как

Посоветуйте плиз видио или статью. Про внутреннее устройство Кафки с точки зрения потоков JVM.

?

Зачем?

Ну там не много "с точки зрения потоков jvm"

Переведённую  книгу могу загрузить, если нужно кому

Пожалуйста, без вареза.
А по теме, не проще глянуть исходники интересующих мест?

Ок)

Английская версия лежит на сайте конфлюента

Судя по дискуссии в нашем уютном чатике про event-driven системы  и как лучше моделировать события / сообщения, не все еще успели почитать отличную книгу Бена Стопфорда про построение таких систем.
Бен представляет сначала концептуальный материал, потом показывает как можно использовать Kafka Streams и KSQL для постоения вот таких систем.
Держите книгу (без смс)!
Кстати, на сайте конфлюента лежат книги по Кафке и обработке стримов, а не все про это знают!
Ловите тоже (там надо оставить email)!

Спасибо)

Добрый день коллеги, вопрос по MirrorMaker, мониторинг данного процесса можно только исключительно из JMX метрик самой кафки получить (или зукипера)?

Ситуация была недавно. Подключился  , а прочитать не могу. Просто висит. Ничего не происходит. Во всех логах тишина

Коллеги, а поделитесь материалом по поводу реализации kafka multi data center

Как это ничего не происходит, более подробно опиши
И конфиги клиента