У меня есть приложение Kafka Streams. У меня не было проблем с rocksdb или Kafka Streams, пока мы...
После того, как все брокеры Kafka перезапустятся, чтобы обновить настройку offset.retention.minutes...
Я хочу объединить потоки из двух разных тем Kafka с помощью API Kafka Streams. Обе темы связаны с...
Надеюсь, это не слишком близорукий вопрос, но я изо всех сил пытался понять, как работает Apache...
У меня есть два микросервиса проекта с пружинной загрузкой 1.5.9.RELEASE, первый микросервис...
У нас есть разработка в kafka-streams, которая производит вид агрегации временного окна:...
Рассмотрим настройку потокового приложения с темой ввода из 6 разделов с хранилищем состояний....
Мы используем Kafka Streams для потребления, обработки и производства сообщений, а в PROD env мы...
Я понимаю, что по умолчанию TTL установлен на бесконечность (не положительно). Однако если нам...
В низкоуровневом API процессора я хотел удалить ключ из хранилища сразу после того, как...
получение приведенной ниже трассировки стека ошибок при работе с потоками kafka ОБНОВЛЕНИЕ:...
Я пишу приложение, в котором пытаюсь подсчитать количество пользователей, которые посещают страницу...
У меня есть приложение Kafka Streams, которое читает журнал изменений в магазине и иногда выдает...
Я группирую поток по ключу и пытаюсь агрегировать значения по сгруппированному ключу. Я следую за...
Иногда я нахожу исключение UNKNOWN_PRODUCER_ID при использовании потоков kafka. 2018-06-25 10:31:38
Мы агрегируем в окнах сеансов, используя следующий код: .windowedBy(SessionWindows.with(...))
Используя коннектор kafka, я записываю данные в формате avro в тему kafka, а затем, используя...
Я использую низкоуровневый API-процессор.У меня есть тема с 6 разделами.В классе, который реализует...
Я не понимаю, почему хранилище statStore пусто в этой топологии: StreamsBuilder builder = new...
Я публикую Kafka с сообщениями JSON, например: "UserID":111...
Что означает, что в столбце CURRENT-OFFSET отображается "-"? TOPIC PARTITION CURRENT-OFFSET...
Я работаю над Kafka Streams.Я сталкиваюсь со следующими проблемами: Подробная информация о том, что...
KStream<String, String> left = builder.stream("source1"); left
Какова стратегия / лучшие практики, когда мы сталкиваемся с ошибкой несовместимости схем (avro),...
Во время прохождения через итератор при периодическом выполнении метода пунктуации, если произойдет...