У нас есть кластер kafka, работающий со схемами Avro, которые хранятся в реестре схем Confluent....
Дано: иметь по два KafkaStreams с топологией DSL каждый. К одной из типологий добавлено локальное...
Я хочу правильно удалить объект из KTable. У меня есть следующие данные потоковой обработки: input
Скажем так, у нас есть 2 темы Пользователи {'UserId', {'UserName', 'Age'} Posts {'PostId',...
Кафка Потоки 2.1.0 на MS Windows здесь. Я нахожусь на macOS, поэтому не могу работать с ним сам, но...
Я пытаюсь создать приложение, которое принимает входящие события и объединяет номера IMEI с...
Как отправить запрос RPC другому экземпляру того же экземпляра приложения Kafka Streams в той же...
Я использую потоки мерцания в микросервисной архитектуре для передачи данных ETL из сервисов в базы...
Я создаю приложение, которое должно извлекать историю потоковых преобразований для конкретного...
Мне нужно сохранить потоковые данные в майскую базу данных Casandra, используя Kafka spark stream....
Приложение собирает тысячи метрик в теме Кафки «raw-метрики». Хранение их в необработанном формате...
У меня есть базовое приложение Kafka Streams, которое читает из in_topic, выполняет скользящий...
Я использую процессор kafka api и создаю хранилище состояний из темы из 3 разделов (у меня есть 3...
Я работаю над своим первым Kafka Stream с использованием Java, и, по сути, я пытаюсь прочитать...
Это вся топология, представленная двумя входными темами (inputTopic1 и inputTopic2) и одной...
В настоящее время я работаю над небольшим проектом Kafka Streams с целью автоматической настройки...
ProcessorContext.schedule(..) принимает параметр интервала продолжительности, и мы могли бы указать,...
Дано: топология DSL с KStream::transform. В рамках выполнения Transformer::transform из входного...
При попытке получить локальное хранилище состояний из KafkaStreams возможно получить исключение...
Как работают полные операции состояния в приложении Kafka Stream с несколькими экземплярами? Скажем...
У меня есть требование, когда я хочу отправить данные с истекшим сроком в долгосрочную базу данных....
В нашей топологии Kafka Streams есть некоторые знаки пунктуации, запуск которых может занять много...
У нас есть топология Java Kafka Streams, построенная с использованием Processor API. В топологии у...
Я написал этот код в потоковом приложении Kafka: KGroupedStream<String, foo> groupedStream =...
мы начинаем работать с потоками Kafka, наш сервис очень простой пользователь без сохранения...