Мне нужно использовать Kafka с socket-socketIO для проекта.Поэтому я решил использовать приложение...

Может кто-нибудь помочь мне решить это?Я пытаюсь скомпилировать проект maven, используя java, spark...

Я запустил коннектор в кластере kubernetis с зарегистрированным плагином. Можно ли запускать...

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

Я пытаюсь запустить простой пример Кафки в проекте Spark. Искра построена правильно, поэтому я могу...

Я новичок в Spark-Streaming и Kafka.С помощью следующего кода я могу использовать сообщения Кафки,...

Я использую docker swarm для настройки контейнера kafka-queue по какой-то причине, так как 3 дня...

По умолчанию хранилища состояния Kafka Streams «компактны».Можно ли установить «сжатие, удаление» с...

У меня есть рабочий процесс для приема и десериализации сообщения kafka avro с использованием схемы...

У меня есть следующий код: - def writeToCassandra(cassandraConnector: CassandraConnector) = new...

У меня есть базовое понимание искры, и я пытаюсь найти что-то, что может помочь мне достичь...

Я запускаю приложение Kafka Streams в Docker-контейнере с помощью docker-compose.Тем не менее,...

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

Я пытаюсь проверить ksql в режиме без головы.Я добавил запрос Create Table в файл запроса и...

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

У меня есть потоковое приложение с 2 тематическими источниками.одна тема читается как KStream, а...

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

Можно ли пересылать входящие сообщения с пользовательскими заголовками из темы A в B в потоковом...

Моя проблема заключается в следующем: У меня есть 2 темы kafka: customer-purchase: содержит...

Разработано: хотите реализовать scala-код с использованием структурированной потоковой обработки...

Я работаю над приложением Spark, которое передает данные из двух разных тем topic_a и topic_b...

Я пытаюсь поэкспериментировать с группами потребителей Вот мой фрагмент кода public final class App...

Я пытаюсь передать потоковый кадр Spark потребителю Kafka.Я не могу сделать, не могли бы вы дать...

Я использую Kafka 0.9.0 и Spark 2.1.0 My Spark Submit следующим образом: ./spark-submit --jars...

Я написал код для извлечения записей из кафки в спарк.Я столкнулся с каким-то странным поведением