#spring_kafka — Public Fediverse posts
Live and recent posts from across the Fediverse tagged #spring_kafka, aggregated by home.social.
-
IllegalMonitorStateException. Красим код в поисках монитора
Статья настоящий разбор-детектив: почему неблокирующий API может блокироваться, как потерять монитор после деоптимизации JIT, почему try-catch иногда важнее коллбэков, и как решать сложные проблемы новыми концепциями мышления. Приятного чтения!
-
Kafka, таксономии и удаление событий: как исключить обработку неактуальных сообщений
В рамках задачи по обработке XBRL-таксономий возникло требование: если таксономия удалена до обработки событий расчёта кэша, эти события не должны приводить к созданию данных для уже неактуальной сущности. На первый взгляд кажется, что достаточно найти соответствующие сообщения и удалить их из Kafka topic. Но Kafka хранит данные как commit log, поэтому точечное удаление сообщений по версии таксономии или другому бизнес-признаку оказывается небезопасным. В статье рассмотрим, почему прямое удаление сообщений не подошло, какие варианты были рассмотрены и как в итоге был применён комбинированный подход: стабильный Kafka key, tombstone-сообщения, compact/delete policy и проверка состояния таксономии на стороне consumer. Разберём решение
https://habr.com/ru/articles/1035526/
#kafka #spring_boot #Spring_Kafka #java #микросервисы #tombstone_objects #Compacted_topic #log_compaction #consumer #идемпотентность