Spark имеет полезный API для накопления данных безопасным для потоков способом https://spark.apache

Так что в основном у меня есть класс Account.У меня есть данные.Я хочу отправить эти объекты в мою...

У меня есть сценарий, в котором мне нужно изменить структуру сообщения, которое я получаю от...

Я получаю CSV в теме Кафки «raw-data», цель состоит в том, чтобы преобразовать их, отправив каждую...

Есть ли способ использовать ту же тему в качестве источника для двух разных подпрограмм обработки...

История вопроса В настоящее время мы используем: API-интерфейс Kafka Streams (версия 1.1.0) для...

Я пытаюсь сериализовать HashMap<String, String>, которые представляют собой некоторые...

Итак, вопрос заключается в безопасности использования внешнего хранилища состояний внутри потоковых...

Для многих ситуаций в больших данных предпочтительно работать с небольшим буфером записей на ходу,...

Я хочу агрегировать какое-то значение, используя временное окно 24 часа, оно работает нормально, но...

Могу ли я использовать процессор api в Kafka Streams и считывать данные из темы в одном кластере...

При каких обстоятельствах программа Kafka Streams должна сериализоваться / десериализироваться

Я пишу приложение для библиотеки книг, и у меня есть 2 микросервиса: memberService и bookService

Поведение приложения моих потоков не такое, как ожидалось: У меня есть один потребитель и один...

Я занимаюсь разработкой журнала Kafka Stream. Планируется использовать файловый кэш в BLOB-объекте...

Если я создаю и запускаю экземпляр KafkaStream, а затем при вызове перехватчика shutdown .close ()...

Кто-нибудь опубликовал ответ на эту проблему?Были и другие посты без ответов.Наша ситуация...

Я использую Кафку 0.11. Я не нахожу класс StoreBuilder в kafka-streams-0.11.0.0.jar. Есть идеи, в...

У нас есть топология потоков, которая будет работать на нескольких машинах. Мы храним результаты...

У меня есть топология потока, определенная с помощью таблицы kafka: stream ... //irrelevant steps

мы пытаемся отойти от нашего сервера приложений J2EE классической архитектуры / реляционной базы...

В моем приложении kafka streams я использую одну тему для нескольких типов объектов, сериализуемую...

Я пытаюсь сделать простой stream.leftJoin(table), но получаю следующее исключение во время...

Мое приложение Kafka streams можно запустить в Ubuntu 16.04, но когда я запускаю его в suse 11 sp4,...

Привет, я получаю эту ошибку компиляции - Unspecified Value parameters: aggregator: (String, String...