Я новичок в kstreams и хочу понять некоторые процессы. Функция агрегирования создает тему kafka с...

Я разрабатываю REST API во Flask , получая данные от Кафки в режиме реального времени . Мне нужно...

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

Во всех уроках Kafka, которые я читал, все они упоминали "разделы Kafka неизменны". Однако я также...

Мне бы хотелось иметь планировщик, который позволял бы мне создавать сообщения на темы AVRO через...

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

У нас есть простой искровой поток из темы кафки (с 8 разделами), созданный как показано ниже и...

У меня проблемы с обработкой потока из темы в одну и ту же тему (она называется «ресторан»)....

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

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

Я пытаюсь отправить json-строку из kafka и сохранить ее в hdfs-файлах json, используя...

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

У меня есть код, который пишет Кафке в транзакции. Это следует за этим форматом: public void...

У меня есть входящие данные для автомобилей и я хочу создать новое событие для поездок. У меня есть...

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

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

В настоящее время мы загружаем сообщения Kafka в HDFS, используя Spark Streaming. Пока что мы...

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

Я слежу за документацией по потокам Кафки, и меня смущают некоторые концепции, которые я хочу...

У меня проблемы с использованием Kafka в unity3d на Mac. Я выполнил шаги, описанные в решении,...

Я новичок в kafka, мне нужна помощь в разработке подхода для работы с конкретным сценарием. У меня...

Я хочу обработать поток искр, который исходит от Кафки.Я использую lowerByKeyAndWindow для...

Мне нужно создавать ежедневные и еженедельные дайджесты электронных писем для всех событий,...

Мне нужно хранить и извлекать смещения Кафки из задания Spark Dataframe в пакетном режиме ,...

В нашей библиотеке есть процессоры данных (код Scala), которые используют типичный поток kafka:...