Публикации по теме 'kafka-streams'
Приложение Kafka Kstream на Java
Kafka — это распределенная платформа потоковой передачи, которая используется для создания конвейеров данных в реальном времени и потоковых приложений. Он предоставляет способ публикации и подписки на потоки данных, а также платформу для хранения, обработки и запроса этих данных.
KStream — это библиотека Java для создания потоковых приложений с использованием Kafka. Он предоставляет высокоуровневый API для работы с потоками Kafka, позволяя разработчикам легко считывать данные из разделов..
Создание масштабируемой службы прогнозирования цен на акции с помощью Hadoop, Kafka, Spark и FBProphet
Мы живем в эпоху, когда аналитика в реальном времени становится необходимостью для многих предприятий. Это позволяет предприятиям реагировать без промедления. Они могут использовать возможности или предотвращать проблемы до того, как они возникнут.
Предисловие
Диплом специалиста Nanyang Poly в области управления большими данными (ITD35X) — мой последний сертификат в моем полуторагодичном путешествии по большим данным и машинному обучению в NYP. Эта статья о последнем 5-недельном..
Как справиться с исключением «Неинициализированная тема» в потоках Kafka
Как исправить это распространенное исключение
В одной из моих предыдущих статей говорилось о тестировании приложений Kafka Streams. Вот совет, который может пригодиться!
Во время тестирования вы можете встретить java.util.NoSuchElementException: Uninitialized topic исключение. Скорее всего, это связано с тем, что вы вызвали TestOutputTopic.readValue (например, как часть проверки assert ). Проблема не в самом исключении, а в сообщении об ошибке Uninitialized topic , которое..