mastodon.world is one of the many independent Mastodon servers you can use to participate in the fediverse.
Generic Mastodon server for anyone to use.

Server stats:

8.9K
active users

#kafka_consumer

3 posts3 participants0 posts today
Habr<p>Kafka: ребалансировка изнутри</p><p>Привет! Меня зовут Геннадий, я руковожу командой разработки системы учета товаров в Ozon. Мы активно используем Kafka как основной инструмент для асинхронного взаимодействия между нашими сервисами. Для нас Kafka — это не просто очередь сообщений, а один из ключевых компонентов всей архитектуры. Поэтому мы постоянно погружаемся в его тонкости и нюансы, чтобы грамотно настраивать и использовать его возможности. Думаю, многие из вас сталкиваются с тем же — когда Kafka становится критически важной частью вашего решения. Хотя информации о ребалансировке Kafka достаточно, она часто либо слишком разрозненная и техническая, либо наоборот — поверхностная и без акцента на важные детали. Я собрал для вас самое важное и объясню это простым и понятным языком.</p><p><a href="https://habr.com/ru/companies/ozontech/articles/910568/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="ellipsis">habr.com/ru/companies/ozontech</span><span class="invisible">/articles/910568/</span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/rebalance" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>rebalance</span></a> <a href="https://zhub.link/tags/consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>consumer</span></a> <a href="https://zhub.link/tags/microservices" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>microservices</span></a> <a href="https://zhub.link/tags/cloud" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>cloud</span></a> <a href="https://zhub.link/tags/devops" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>devops</span></a></p>
Habr<p>Кафка: преимущества и на что ещё обратить внимание при тестировании</p><p>Привет, Хабр! Ранее мы разбирались с основами Kafka ( часть1 ), рассматривали, как тестировать микросервисы ( часть2 ) и предугадывали ошибки offset explorer и kafka ui ( часть 3 ). В этой части – так сказать, невошедшее, но полезное, что ещё можно предусмотреть при работе с брокером. Преимущества брокеров Когда я готовила материал из первой части, у меня возникло несколько предположений. Мне казалось, что некоторые преимущества относятся именно к брокерам сообщений и не имеют прямого отношения к API (временное хранение данных, обмен в реальном времени, вычитка раз в сутки, отслеживание Kafka-лага). Особенно я задумалась об этом, когда разбирала пример с мобильным веб-приложением и форматами данных для Kafka (см. раздел из статьи часть1 ). Казалось бы — зачем Kafka, если можно просто забирать данные из БД через API? Я решила проверить свои догадки у знакомого бэкенд-разработчика. Его первый вопрос был: «Зачем тебе как тестировщику это знать?», а потом добавил, что API можно настроить похожим образом. Но всё же я выделила два ключевых отличия брокеров: 1. Асинхронное взаимодействие API — это всегда запрос-ответ. Если сервис упал, мы получим 503, и данные могут потеряться. В Kafka продюсер просто оставляет сообщение в топике, и ему всё равно, читает ли его кто-то. Даже если консьюмер упал — поднимется и дочитает. 2. Масштабируемость В случае с Kafka это значит, что можно гибко добавлять продюсеров и консьюмеров. Данные можно переиспользовать — допустим, создать один топик для нескольких консьюмеров. Либо, что очень важно в продакшене, например, если продюсер начал слать мусор — его можно просто отключить.</p><p><a href="https://habr.com/ru/companies/reksoft/articles/911132/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="ellipsis">habr.com/ru/companies/reksoft/</span><span class="invisible">articles/911132/</span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/%D0%BC%D0%B8%D0%BA%D1%80%D0%BE%D1%81%D0%B5%D1%80%D0%B2%D0%B8%D1%81%D1%8B" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>микросервисы</span></a> <a href="https://zhub.link/tags/%D1%82%D0%B5%D1%81%D1%82%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B5" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>тестирование</span></a> <a href="https://zhub.link/tags/%D0%B1%D1%80%D0%BE%D0%BA%D0%B5%D1%80%D1%8B" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>брокеры</span></a> <a href="https://zhub.link/tags/%D1%82%D0%B5%D1%81%D1%82%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B5_%D0%BC%D0%B8%D0%BA%D1%80%D0%BE%D1%81%D0%B5%D1%80%D0%B2%D0%B8%D1%81%D0%BE%D0%B2" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>тестирование_микросервисов</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/kafka_producer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_producer</span></a></p>
Habr<p>DLQ-first: учим Kafka-консьюмера падать красиво и поднимать поток за секунды</p><p>Привет, Хабр! Сегодня рассмотрим, как построить Kafka-консьюмер, который не падёт при первой же проблеме, а аккуратно сложит битые события в Dead Letter Queue (DLQ).</p><p><a href="https://habr.com/ru/companies/otus/articles/905810/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="ellipsis">habr.com/ru/companies/otus/art</span><span class="invisible">icles/905810/</span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/apache_kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>apache_kafka</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/dlq" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>dlq</span></a> <a href="https://zhub.link/tags/%D0%BF%D0%BE%D1%82%D0%BE%D0%BA%D0%BE%D0%B2%D0%B0%D1%8F_%D0%BE%D0%B1%D1%80%D0%B0%D0%B1%D0%BE%D1%82%D0%BA%D0%B0_%D0%B4%D0%B0%D0%BD%D0%BD%D1%8B%D1%85" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>потоковая_обработка_данных</span></a> <a href="https://zhub.link/tags/stream_processing" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>stream_processing</span></a></p>
Habr<p>Kafka: как тестировать. Часть 2</p><p>Привет, Хабр! Это вторая часть статьи о Kafka (первая тут ). Давайте продолжим разбираться. Итак, часто тестирование сводится к эмуляции работы сервиса и наблюдением за топиками кафки. Для этого необходимо подключиться к кластеру кафки с теми же правами доступа, что и у вашего сервиса либо сервиса, с которым у вас интеграция (креды для кластера обычно подсказывают коллеги-разработчики, девопсы, тестировщики)....</p><p><a href="https://habr.com/ru/companies/reksoft/articles/900918/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="ellipsis">habr.com/ru/companies/reksoft/</span><span class="invisible">articles/900918/</span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/kafka_%D0%B2_%D1%82%D0%B5%D1%81%D1%82%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B8" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_в_тестировании</span></a> <a href="https://zhub.link/tags/kafka_producer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_producer</span></a> <a href="https://zhub.link/tags/%D1%82%D0%B5%D1%81%D1%82%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B5" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>тестирование</span></a> <a href="https://zhub.link/tags/%D0%BC%D0%B8%D0%BA%D1%80%D0%BE%D1%81%D0%B5%D1%80%D0%B2%D0%B8%D1%81%D1%8B" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>микросервисы</span></a> <a href="https://zhub.link/tags/%D1%82%D0%B5%D1%81%D1%82%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B5_%D0%BC%D0%B8%D0%BA%D1%80%D0%BE%D1%81%D0%B5%D1%80%D0%B2%D0%B8%D1%81%D0%BE%D0%B2" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>тестирование_микросервисов</span></a></p>
Habr<p>Kafka. Лучшие практики применения. Настройки Prudcer &amp; Consumer</p><p>Привет, Хабр! Меня зовут Михаил, я являюсь ФинТех системным аналитиком, исполняющим роль архитектора на проектах. И сегодня я хочу поделиться материалами по Kafka, которые подготовил для обучения сотрудников из своей команды. В материале постарался отразить самые важные технические моменты по Kafka, которые будут подкреплены наглядными кейсами и примерами использования. Материал будет полезным как для начинающих, так и для продвинутых пользователей. Желаю приятного прочтения. Kafka. Лучшие практики применения.</p><p><a href="https://habr.com/ru/articles/853652/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="">habr.com/ru/articles/853652/</span><span class="invisible"></span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/%D0%BA%D0%B0%D1%84%D0%BA%D0%B0" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>кафка</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/producer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>producer</span></a>/consumer <a href="https://zhub.link/tags/producer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>producer</span></a> <a href="https://zhub.link/tags/consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>consumer</span></a> <a href="https://zhub.link/tags/kafkaconnect" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafkaconnect</span></a> <a href="https://zhub.link/tags/kafka_listener" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_listener</span></a> <a href="https://zhub.link/tags/kafka_apache" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_apache</span></a> <a href="https://zhub.link/tags/kafka_connect" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_connect</span></a></p>
Habr<p>Ручное подтверждение сообщения в Kafka</p><p>В этой статье описывается реализация задачи ручного подтверждения(acknowledgment) обработки сообщения в Kafka через ручную отправку смещения(commit offset) сообщения. Логика реализована с использованием Java, Spring и Kafka.</p><p><a href="https://habr.com/ru/articles/808975/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="">habr.com/ru/articles/808975/</span><span class="invisible"></span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/kafka_listener" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_listener</span></a> <a href="https://zhub.link/tags/spring" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>spring</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a> <a href="https://zhub.link/tags/kafka_acknowledgment" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_acknowledgment</span></a> <a href="https://zhub.link/tags/kafka_offset" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_offset</span></a></p>
Habr<p>Как работать с Kafka-consumer в Spring-проектах</p><p>Эта статья сборник небольших рекомендаций как работать с Kafka-consumer в Spring основанных на личном опыте.</p><p><a href="https://habr.com/ru/articles/793134/" rel="nofollow noopener noreferrer" translate="no" target="_blank"><span class="invisible">https://</span><span class="">habr.com/ru/articles/793134/</span><span class="invisible"></span></a></p><p><a href="https://zhub.link/tags/kafka" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka</span></a> <a href="https://zhub.link/tags/spring" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>spring</span></a> <a href="https://zhub.link/tags/java" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>java</span></a> <a href="https://zhub.link/tags/kotlin" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kotlin</span></a> <a href="https://zhub.link/tags/kafka_consumer" class="mention hashtag" rel="nofollow noopener noreferrer" target="_blank">#<span>kafka_consumer</span></a></p>