Кто-нибудь знает, можно ли назвать writeStream темой Кафки, где создаваемая тема является...
Я новичок в области больших данных, мне нужно сделать демонстрацию, которая транслирует данные из...
Я думаю, что эта проблема связана с # 539 , но я не знаю, является ли это ошибкой, или пользователь...
Я пытаюсь транслировать данные из Твиттера о различных предметах: музыке, политике, спорте и т. Д.,...
В пользовательском Transformer мы пытаемся создать и переслать некоторые записи в методе init(..)....
Я пытаюсь использовать потоки Кафки, чтобы выполнить оконную агрегацию и выдать результат только...
У меня есть поток kafka, я буду обрабатывать в искре.Я хочу записать вывод этого потока в файл
Я хочу создать интерактивные условия для своего потока kafka.Я просто хочу знать, возможно ли это....
Я ищу способ сделать инструмент повторной обработки в KafkaStreams, который позволит повторно...
У нас есть экземпляр kafka с примерно 50M записями, с входом около 100k в день, так что в мире...
Я пытаюсь объединить два JavaPairDStream в JavaPairDStream с помощью метода JavaStreamingContext
Я довольно долго боролся с этой проблемой.Я работаю над AvroProducer (confluent kafka) и получаю...
Есть ли способ, которым рабочая группа может запретить командам приложений создавать промежуточные...
Я работаю над созданием потока DLQ. При попытке использовать сообщение с ошибкой, после 3 попыток...
Наше потоковое приложение kafka продолжает открывать новые файловые дескрипторы, пока они являются...
Это длинный вопрос, но я попытался подробно описать проблему. У меня есть приложение Spark на...
У меня есть загрузочное приложение Spring, которое использует Processor API для создания топологии,...
Допустим, у меня есть поток событий. R1 - {"abc": "значение 1"} R2 - {"abc": "значение 2"} R3 -...
Я пытаюсь запустить потоковое приложение искры с Kafka, используя пряжу.Я получаю следующую ошибку...
Что происходит в приложении KafkaStreams, если ему не удается зафиксировать смещение из-за...
У меня есть следующий код .Моя цель - сгруппировать сообщения по заданному ключу и 10-секундному...
При построении топологии Kafka Streams чтения из нескольких тем можно моделировать двумя различными...
У меня следующий вопрос. Я использую задание Spark Structured Streaming, которое читает одну тему и...
Вариант использования: учетная запись A отправляет 500 баксов на учетную запись B, мы используем...
В python spark я хочу знать, возможно ли настроить моего собственного потребителя kafka с потоковой...