У меня есть потоковое приложение, которое непрерывно принимает поток координат вместе с некоторыми...
Насколько я понимаю, вы можете использовать методы process или transform для определения...
Я надеюсь, что вы можете мне помочь.Давайте, например, воспользуемся этим очень простым кодом...
Я бы хотел перенаправить сообщения kafka из темы "all-topic" в тему с именем " headervalue -topic",...
Вариант использования Kafka: непрерывное чтение из Kafka (возможно, из потока), выполнение...
РЕДАКТИРОВАТЬ В случае, если кто-то еще находится в этой конкретной ситуации, я получил что-то...
У меня есть несколько экземпляров потокового приложения Kafka.Чтобы запросить ключ из магазина, я...
По умолчанию .windowedBy(SessionWindows.with(Duration.ofSeconds(60)) возвращает запись для каждой...
У меня есть приложение Kafka Streams, которое читает одну тему Kafka с 5 разделами. Затем данные...
В настоящее время я работаю над обслуживанием недокументированного кода и наткнулся на странную...
В простой программе Kafka Stream, когда я использую приведенный ниже код, она работает без...
Фон - Данные временных рядов поступают в Apache Kafka, который я храню в Cassandra. Поскольку...
My STORE_TOPIC - это сжатая тема, которая содержит текущее состояние моих сущностей на основе...
У меня есть входные данные, которые я получаю, используя Kafka Stream.То, что мне нужно реализовать...
Мы столкнулись со следующей проблемой: Существует служба (приложение kafka-streams), которая была...
Я пытаюсь сгенерировать счет на основе ключей, используя приведенный ниже код, этот код основан на...
Я пытаюсь определить поток kafka, который принимает записи из темы, скажем, EMPLOYEE, где записи...
Я использую API процессора Kafka Streams для создания приложения Kafka Streams для получения...
Наличие топологии KafkaStreams, которая потребляет и после некоторых этапов обработки выдает...
Создан поток из темы и успешно получены мои данные на основе фильтра после stream.start ().но моя...
Существует топология: kStreamBuilder.stream(kafkaProperties.getInboundTopicName(), consumed)
У нас есть следующая топология с двумя преобразователями, и каждый преобразователь использует...
Я нахожу эту проблему в журналах приложения Kafka Streams (версия 2.1). Coordinator selected...
Я новичок в Apache Kafka. Я должен синхронизировать наших студентов и их регистрации. Всякий раз,...
У меня есть требование получить метку времени (событие-время), когда сообщение было сгенерировано,...