Допустим, у меня есть 2 потока kafka (библиотека kafka-streams-scala, версия 2.2.0): val builder:...

Я работаю в проекте сбора данных об изменениях. У меня есть база данных MySQL. Я использую дебезиум...

Я впервые использую pyspark. Версия Spark: 2.3.0 Версия Kafka: 2.2.0 У меня есть производитель...

У меня есть приложение структурированного потокового вещания Spark (v2.3.2), которое нуждается в...

У меня есть приложение KStream с кучей KStreams, объединений и других операций. Я включил logging

Учитывая данные, которые я извлек из Kafka. Как извлечь из него значения с помощью сопоставления с...

Мой вопрос очень близок к Печать Kafka Stream Input на консоль? с небольшой разницей: я использую...

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

Есть ли способ интегрировать потоковую передачу Apache Spark с Apache Hive и Apache Kafka в одном...

Есть ли способ напечатать сообщение отладки Kafka (я думаю о сообщениях журнала, которые похожи на...

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

Как передать конкретное значение смещения, скажем, из 25-го смещения (возможно, из базы данных) в...

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

У меня есть данные, которые слишком велики для одного сообщения.Рассмотрим avro: record Likes {...}...

У меня есть следующий код: val rawWeatherStream = KafkaUtils.createDirectStream[String, String,...

Я локально запускаю приложение (Spring Boot и Spring Cloud Stream, Kafka Binder и Kafka Streams...

Я реализую Kafka listerner (Consumer) с загрузкой Spring, событие приходит к методу, который должен...

Я работаю над сценарием использования, в котором я создал конвейер, который отправляет данные из...

Я пытаюсь создать самый простой мир привет с помощью Spring Cloud + Kafka Streams + Spring Boot 2....

Я пытаюсь запустить потоковое приложение, которое считывает данные из потока kafka и обрабатывает...

Spring Kafka и, следовательно, Spring Cloud Stream , позволяют нам создавать транзакционных...

Мы получаем данные с сервера Kafka, где каждая тема имеет 10 разделов.Мы обрабатываем его с помощью...

У меня есть СДР, преобразованный в dataFrame следующей структуры:...

Я разработал приложение Spark Streaming, которое работает на 120-секундных микропакетах, по сути,...

Я использую SparkStreaming для чтения данных из темы. Я сталкиваюсь с исключением в этом. java.io