Poll() что происходит после вызова consumer.subscribe()После того, как consumer запустился, получил свои group.assignment на topic — он подписывается на него.Sep 1, 2024Sep 1, 2024
ConsumerGroup RebalanceКак происходит Rebalance в Kafka Consumer Group, кто за него отвечает и когда происходит RebalanceSep 1, 2024Sep 1, 2024
Heartbeat in KafkaЧто такое Heartbeat, как работает механизм и зачем нужен в KafkaSep 1, 2024Sep 1, 2024
Подготовка к rebalanceСуществует всего 3 триггера, при которых GroupCoordinator может инициировать процедуру rebalance:Jul 17, 2024Jul 17, 2024
прерываем thread.sleep() по запросу. С серверов linux без перезапуска приложения. Java+SpringДопустим у нас на серверах Linux размещено приложение, которое делает определенные действия раз ы пол часа, после этого пол часа оно…Jul 3, 2024Jul 3, 2024
LOGGER JAVA со спеиальными условиямииногда приходится настраивать логгер с учетом разных условий. Например — писать раз в 5 минут, или писать только если ошибка изменилась…Jun 23, 2024Jun 23, 2024
LOG4j — Как его настраиватьВ данном примере log файла показано как настроить log4j и заставить его делать именно то, что вам нужно:Feb 28, 2024Feb 28, 2024
Отслеживание Native Memory при работе Java приложение на сервере linuxЧто такое встроенное отслеживание памяти (NMT), и как можно его использовать для обнаружения проблем с чрезмерным использованием памяти…Feb 28, 2024Feb 28, 2024
Confluent Schema Registry CompatibilityМы говорим, что schema в topic определяет структуру данных message. Именно она определяет разрешенные типы данных их формат и т.д. Но…Feb 22, 2024Feb 22, 2024
