Публикации по теме kafka-streams

Публикации по теме 'kafka-streams'

Ручное подтверждение сообщения на Kafka

Kafka Consumer используется приложениями, которым необходимо считывать данные из Kafka, чтобы подписываться на темы и получать сообщения из этих тем. Есть несколько разных понятий и идей, связанных с чтением данных из Kafka по сравнению с чтением данных из других систем обмена сообщениями. Без предварительного понимания этих идей сложно понять, как использовать потребительский API. Затем мы рассмотрим несколько примеров, демонстрирующих различные способы использования потребительских..

Kafka KStream присоединяется к Java

Соединения KStream позволяют объединить два потока данных по общему ключу и создать новый поток объединенных записей. Это может быть полезно для объединения данных из нескольких источников или для выполнения операций с данными, для которых требуется информация из нескольких потоков. Например, представьте, что у вас есть два потока данных: один содержит информацию о пользователях, а другой — информацию о приобретенных ими продуктах. Вы можете использовать соединение KStream, чтобы..

Служба очереди сообщений с использованием Kafka

В этой статье мы собираемся создать службу очереди сообщений, используя Kafka и KafkaJS, что-то похожее на SQS, и мы позаботимся о том, чтобы сообщения обрабатывались ровно один раз в том порядке, в котором они отправляются. Мы также реализуем механизм повторной доставки, чтобы убедиться, что если что-то не работает в нашей бизнес-логике, мы можем снова добавить это в очередь. Найдите исходный код на Github : https://github.com/icpsoni/kafka-message-queue Предпосылки 1...

Kafka Streams — Как рассчитать скользящее среднее для потока данных о ценах на акции в режиме реального времени

Пошаговое руководство по расширенному программированию Kafka Streams — KTable, Time Windows и Aggregation Обработка потока данных в реальном времени не ограничивается фильтрацией и преобразованием значений, мощная структура позволяет выполнять гораздо более сложные вычисления. Типичным примером является технический анализ фондового рынка. Технические индикаторы интригуют, поскольку они являются полезными инструментами, дающими трейдерам ценную информацию и ценные рекомендации по..

Настоящая демонстрация Kafka на Wirecard Brazil

Kafka - действительно крутая и мощная платформа, и, поскольку у нас в Wirecard Brazil много замечательных инженеров-программистов, я хочу поговорить о том, как мы здесь используем Kafka, о проблемах, которые мы стремимся решить, и о проблемах, которые возникли во время разработки. В этом посте вы не найдете никакого кода, я не собираюсь показывать шаг за шагом, как его реализовать. Вы найдете реальный пример Kafka, показывающий: почему мы решили его реализовать, как мы это сделали,..

Установка Apache Kafka на Mac (OSx).

Установка и настройка среды для Kafka на mac os. Для установки Apache Kafka на Mac или любую другую систему требуется только Java (Java 8). Сначала мы рассмотрим этапы установки Java, а затем приступим к настройке Apache Kafka. Установите Java: - Откройте ссылку ниже в браузере Загрузки Java SE Java SE 13.0.1 — это последний выпуск для платформы Java SE. Узнать больше Ищете сборки Oracle OpenJDK? Оракл… www.oracle.com..

Объективы SQL для вашей системы обнаружения вторжений

Объективы SQL для вашей системы обнаружения вторжений В течение последнего десятилетия приложения работали с данными с высокой пропускной способностью почти в реальном времени. Возьмем, к примеру, системы обнаружения сетевых вторжений (NIDS); важный инструмент сетевой безопасности - независимо от вашего определения безопасности. Еще несколько лет назад такие системы требовали дорогостоящих проприетарных аппаратных решений, связанных с программными инструментами поставщиков..