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

Я хочу написать Reactive Kafa для прослушивания нового приходящего сообщения.Но я не знаю, как это...

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

У меня есть распределенная база данных в Apache Ignite и потоковая служба Apache Kafka, которая...

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

Рассмотрим данные, записанные из dataframe в kafka и затем прочитанные из kafka обратно в новый...

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

Я отправляю файл на потоковое воспроизведение с использованием kafka и spark.Искра является...

Приложение слушает 2 темы кафки userevent paymentevent Полезная нагрузка для использованияrevent...

Сообщение Post Telemetry публикуется в теме Kafka. Сбой механизма правил при анализе сообщения...

Мое приложение kafka streams работает нормально, когда я нахожусь в среде, где мой коэффициент...

Мы используем Ktabke для агрегирования в kafka, его очень простое использование и ссылаемся на...

Я хочу потоковую передачу CSV-файлов на спарк с kafka. Все файлы сохраняются в формате hdf другим...

Я пытаюсь прочитать данные из kafka и загрузить их в базу данных greenplum с помощью spark. я...

Я новичок в kafka и spark, удивляюсь, как восстановить смещение от kafka после сбоя задания spark....

Я пытаюсь получить пример работы kafka и spark-streaming, и у меня возникают проблемы при запуске...

Я хочу использовать Kafka Streams Processor API и генерировать некоторые сообщения каждую минуту в...

, когда я пытаюсь получить доступ к стерео состояния из потока, я получаю ошибку ниже, Хранилище...

У меня следующий json из потока Кафки [{timestamp: 2019-01-01T00:00:00z, id:A, value: 3.15}...

Насколько я знаю, искровая структурированная потоковая передача - это отказоустойчивость при...

Мне нужно записать метку времени в раздел Kafka, а затем прочитать ее с нее. Для этого я определил...

Я использую Kafka для очереди, при этом службы Node производят и потребляют сообщения на темы Kafka...

Я использую клиент Confluent's C # Kafka.Когда потребитель начинает потреблять, я наблюдаю с...

Я пытаюсь провести некоторое тестирование с использованием EmbeddedKafkaCluster из библиотеки...

Я создаю Spark Streaming Application и хочу обрабатывать каждое сообщение Кафки отдельно. Сейчас я...