Я потребляю твиты для Кафки-продюсера, а затем поглощаю их для Кафки-потребителя.Я могу заставить...

Проблема: мне нужно узнать, как отправлено сообщение за последние, например, 24 часа.У меня есть...

Я пытаюсь прочитать kafka, используя spark, но, похоже, столкнулся с некоторой библиотечной...

Я реализовал UDF (пользовательскую функцию) для KSQL и настроил файл Maven pom.xml в соответствии с...

Я хочу загрузить все записи из темы кафки, используя spark, но все примеры, которые я видел,...

Я хочу добавить некоторые параметры в мое приложение spark & ​​Kafka для записи Dataframe в тему...

На диаграмме выше показана текущая архитектура, которую я пытаюсь реализовать.В настоящее время я...

Я запускаю несколько экземпляров потребителя потока kafka (2 экземпляра) на моем локальном...

Я хочу написать в кафке тему набор данных JSON У меня есть объекты набора данных, я преобразую его...

Я пытаюсь создать таблицу в потоке, используя двоичный файл ksql. Таблица создается и запускается,...

У меня есть последовательность событий в теме T1 с key в качестве идентификатора сотрудника, value...

Мы работаем над распараллеливанием нашего потребителя Kafka, чтобы обработать большее количество...

У меня есть много приложений по всему миру, которые отправляют данные на мой сервер.все данные...

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

После прочтения этой статьи я смог прочитать из одной темы1 и опубликовать в другой теме2. Но когда...

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

У меня работает два демона telegraf. Демон 1: вход = тема kafka: sample_topic, выход = InfluxDb: DB...

У меня есть приложение Spring Cloud Kafka Streams, которое использует StateStore в Processor API...

Собственный API Kafka позволяет создавать и добавлять хранилище состояний с помощью StreamsBuilder...

Я получаю не сериализуемое исключение при попытке получить и записать значение в HDFS, используя...

У меня есть топология Kafka Streams, которая содержит AbstractProcessor (фактически два). В одном...

У меня есть приложение структурированного потокового вещания, которое читает сообщения от Кафки....

У меня есть структурированное потоковое задание, которое берет сообщения json из очереди kafka и...

Я использую spring-cloud-stream-kafka, версия 2.1.2.И повторите попытку, используя RetryTemplate по...

Кафка очень распространена.Так много компаний используют это.Я полностью понимаю, как работают...