У меня есть поток объектов, где я хотел бы рассчитать среднее значение поля в этом объекте, а затем...
Возможно ли это? Я в основном пишу приложение, которое добавляет определенное количество входящих...
Изначально я сделал более сложное приложение kstream, которое делало много сложных вещей.Работая в...
Давайте предположим простой случай, подобный следующему: ORDER_TOPIC ----> KSTREAM ---->...
Мне интересно узнать, как лучше анализировать журналы для архитектуры микросервисов? , чтобы понять...
В моем преобразовании на основе DSL у меня есть поток -> ветвь, где я хочу, чтобы разветвленный...
Я запускаю несколько экземпляров потребителя потока kafka (2 экземпляра) на моем локальном...
Я использую два разных срока хранения для двух разных KTable, и он работает с состояниями RocksDB и...
Я пытаюсь получить пример работающего "действия" потока kafka в Spring-Boot, и я, кажется, в итоге...
Я занимаюсь обогащением данных, присоединив kstream к ktable.Kstream содержит сообщения,...
По умолчанию .windowedBy(SessionWindows.with(...)) будет возвращать каждую новую входящую запись
У меня есть последовательность событий в теме T1 с key в качестве идентификатора сотрудника, value...
Планируются ли какие-либо усовершенствования или KIP, чтобы мы могли получить доступ к метаданным...
У меня есть много приложений по всему миру, которые отправляют данные на мой сервер.все данные...
Я пытаюсь выяснить, почему моему приложению kafka-streams не хватает памяти.Я уже обнаружил, что...
Как я могу написать модульный тест для метода ниже: public KStream<String, Object>...
Необходимо удалить дубликаты сообщения в пределах временного окна. Сообщение поступает постоянно....
При создании Kafka Streams с использованием Kafka Streams DSL https://kafka.apache
У меня есть приложение Spring Cloud Kafka Streams, которое использует StateStore в Processor API...
Собственный API Kafka позволяет создавать и добавлять хранилище состояний с помощью StreamsBuilder...
У меня есть топология Kafka Streams, которая содержит AbstractProcessor (фактически два). В одном...
Получение исключения при чтении из темы kafka: вызвано: org.apache.kafka.common.errors
Я новичок в kafka и сейчас смотрю на Kafka Streams, особенно объединяю два потока. Примеры, которые...
Следующее поле вызывает сбой моего приложения Kafka Stream при попытке создать сообщение. {...
У меня есть требование, как указано @ https://kafka.apache