Я работаю над своим первым Kafka Stream с использованием Java, и, по сути, я пытаюсь прочитать...
У меня есть кластер kubernetes с одним модулем zookeeper и тремя модулями брокера kafka. Дескриптор...
Я работаю над POC на Kafka Streams, в котором я обрабатываю авро-сообщения с использованием Kafka...
Дано: топология DSL с KStream::transform. В рамках выполнения Transformer::transform из входного...
У меня есть экземпляр контейнера Azure, и я хочу подключиться к кафке, которая также находится в...
мы начинаем работать с потоками Kafka, наш сервис очень простой пользователь без сохранения...
Доброе утро, ребята, Я пытаюсь запустить приложение Kafka Stream, но каждый раз, когда я пытаюсь,...
каждый день мы будем получать сообщения ниже в Student-Topic-In Message 1: {"StudentID":...
У меня есть этот код: import org.apache.spark.sql.SparkSession object TopicIngester { def...
Я использую Confluent 5.0.0 версии * У меня есть массив JSON, как показано ниже: { "name"...
Таким образом, мой вариант использования - использовать сообщения от Kafka в приложении Spring...
Я пытаюсь создать DSL-код Materialized.as здесь: https://kafka.apache
Я пытаюсь провести анализ потоковой передачи данных в Твиттере. Твиты успешно потребляются через...
То, что я хотел бы сделать, это: Использовать записи из темы считать значения для каждого окна...
Я работаю над приложением, которое использует project-reactor API-интерфейсы Kafka для реактивного...
У меня есть программа Spark, которая принимает данные из тем Kafka и файлов HDFS. Эта информация...
Я работаю над приложением Spark Streaming, которое будет принимать сообщения из защищенной темы...
Я пытаюсь создать простое приложение Kafka Streams, используя среду Spring Cloud Stream.Я могу...
Мне нужно, чтобы мой потребитель потреблял определенное количество TopicPartitionOffset(here from...
Я использую Kafka 2.1.0. У нас есть кластер Kafka с 5 брокерами (машины r5.xlarge).Мы часто...
Я написал очень простой конвейер в Apchea Beam, как показано ниже, для чтения данных из моего...
Я пытаюсь собрать Kafka Sink Connector, производитель отправляет сообщения в Avro.Как преобразовать...
У меня следующая проблема с API kafka.Я настроил своего потребителя с помощью: props
Я пытаюсь соединить соединитель Kafka с базой данных, используя соединитель jafb kafka. Я могу...
У нас есть приложение на базе Spring с многоуровневой архитектурой. Слои в следующем порядке Rest...