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


Как создать потоковое приложение с помощью Docker, Redpanda и Apache Spark
Используйте Redpanda и Apache Spark Streaming для создания потокового приложения. Redpanda — это платформа потоковой передачи данных, совместимая с Apache KafkaⓇ API, для критически важных рабочих нагрузок, где важны производительность, безопасность данных и транзакционность. Эта совместимость упрощает использование Redpanda с существующей инфраструктурой, включая Apache SparkⓇ. Spark — это популярный аналитический механизм для крупномасштабной обработки данных. Созданный в..

Кто есть кто?: распознавание лиц в реальном времени
Как импортировать поток изображений в Deephaven IDE Иеремия Ченг Технология распознавания лиц — мощный инструмент — компьютерное зрение может идентифицировать человека, просто сканируя его лицо. Вы сталкивались с этим всякий раз, когда ваш телефон распознает друзей, чтобы помочь вам организовать ваши фотографии, или если вам нужно сканирование лица, чтобы войти в вашу сверхсекретную лабораторию. А если серьезно, технология распознавания лиц служит важным целям правоохранительных..

Прогнозирование оттока клиентов в реальном времени для телекоммуникационных компаний
Прогнозирование оттока в реальном времени для телекоммуникационных компаний Краткое содержание В этой статье представлена ​​экспериментальная система прогнозирования оттока в режиме реального времени для телекоммуникационных компаний с описанием трех модулей, составляющих структуру: модуль издателя, который публикует данные о клиентах в теме Kafka, модуль потребителя, извлекающий данные из Тема Kafka и запись в поток Apache Spark, а также третий модуль, который читает из потока..

Распределенная трассировка с OpenTelemetry, Spring Cloud Sleuth, Kafka и Jaeger
Пошаговое руководство по реализации распределенной трассировки в микросервисах Распределенная трассировка дает представление о том, как конкретный сервис работает как часть целого в распределенной программной системе. Он отслеживает и записывает запросы от точки их отправления до места назначения и систем, через которые они проходят. В этой статье мы собираемся реализовать распределенную трассировку в трех микросервисах Spring Boot, используя OpenTelemetry, Spring Cloud Sleuth, Kafka..

Настройка Kafka Mirror Maker для репликации темы Kafka
Apache Kafka Mirror Maker 2 помогает реплицировать темы в кластерах Kafka. В этой статье мы покажем, как использовать Apache Mirror Maker для репликации тем Kafka в двух кластерах Kafka. Настраивать

Машинное обучение и потоковая обработка Kafka KSQL - ошибка, когда я оставляю обогреватель включенным
Непрерывный мониторинг энергопотребления в домашних условиях с помощью обученной модели для предупреждения о неожиданном потреблении энергии в определенное время суток. Позвольте моему Google Home и телефону уведомлять меня, когда я использую больше электроэнергии, чем ожидалось. Что это, черт возьми? Энергопотребление в домашних условиях колеблется в течение дня. Однако образец использования электроэнергии следует типичной кривой и становится предсказуемым после достаточного..

Kafka — переход на бессерверные технологии
Кафка проще простого. Изучение Kafka как сервиса. Системы, управляемые событиями, повсюду. В последние несколько лет они росли огромными темпами. Это происходит из-за растущей оцифровки всего и множества данных, поступающих в системы каждый день. Пользователям сегодня нравятся только системы, которые решают их проблемы быстро и быстро. Чтобы система могла эффективно решать проблемы пользователя, она должна эффективно обрабатывать постоянно поступающие пользовательские данные. И вот..