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

Я пытаюсь понять kafka stream processor немного больше. Я хочу знать, что такое frequency of...

На основе документации Kafka: можно улучшить пропускную способность в Kafka, создав тему с...

Я использую соединитель приемника HDFS Kafka для записи в HDFS из kafka, он работает нормально. Мои...

Когда я делаю ниже, он работает нормально company_info_df.select(col("value"))

Я новичок в искровом структурированном потоке и офсетном управлении кафкой.Использование...

Мне нужно решить проблему.У меня есть производитель kafka, который производит сообщения (xmls) на...

Я пытаюсь отправить список [KeyValue] в тему в приложении Kafka Streams.Но поток ожидает...

Построение потокового приложения с использованием kafka stream. У меня есть тема с 8 разделами, где...

Наше искровое задание - это очень простое потоковое приложение Kafka, которое потребляет пакет...

Я заметил, что стадия aggregate(), кажется, сериализует / десериализует каждый отдельный элемент,...

я использовал spring-cloud-starter-stream-kafka 2.1.2 Потребители для соответствующей темы были...

Я хочу запустить 2 топологии на одном экземпляре.1 топология включает хранилище состояний, а другая...

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

У меня есть одна тема Kafka с несколькими пользовательскими информационными событиями для...

Я использую кластер Kafka из Bitnami в Azure (https://bitnami.com/stack/kafka/cloud/azure). Это...

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

Я ищу api kafka rest, в котором будут указаны те же данные, что и kafka-consumer-groups.sh - -...

Всякий раз, когда приложение Stream Streaming пытается передать смещение Кафке, оно становится...

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

Я добавил несколько процессоров в свою топологию. Работает только 1 процессор. Я могу получать...

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

Я пытаюсь понять kafka в некоторых деталях относительно потоков kafka (клиент потока kafka для...

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

Я пытаюсь развернуть реестр Confluent Schema в нашей внутренней инфраструктуре AWS (ECS), чтобы он...