#статья #Kafka #API #архитектура #интеграция #брокеры 💥Где и как реализуются гарантии доставки сообщений в/из Kafka и при чем здесь транзакции Аномалии грязного чтения незафиксированных транзакций в Apache Kafka: как потребители могут читать данные, которых не видно в топике, почему это происходит и что обеспечивает гарантию exactly once без дублей и потери сообщений. 🔥Одним из достоинств Apache Kafka принято считать гарантии доставки сообщений с семантикой exactly once, когда каждое опубликованное сообщение будет обработано приложением-потребителем только один раз, даже при сбоях потоковой системы. Это особенно важно для финансовых операций или бронирований ограниченных ресурсов, где повторы или пропуски недопустимы. Однако, на самом деле, это реализуется не брокером сообщений, а обеспечивается верными настройками продюсеров и потребителей. 🙌🏼На стороне приложения-продюсера, которое публикует данные в Kafka, надо обеспечить идемпотентность и транзакционность отправки данных. А на стороне приложения-потребителя, которое потребляет сообщения и обрабатывает их – следует настроить такой уровень изоляций транзакций, чтобы исключить возможность так называемого «грязного чтения», когда результаты одной незафиксированной транзакции становятся видны другим. Как это сделать, читайте в моей новой статье: 👉🏻https://babok-school.ru/blog/exactly-once-and-dirty-read-from-kafka-topic/