Когда вы материализуете магазин из SessionWindowKStream, он заставляет вас делать это как...
Допустим, у меня есть три темы Kafka, заполненные событиями, представляющими бизнес-события,...
Я готовил документ о государственном хранилище, но мне все еще не ясно, может ли он соответствовать...
У меня есть данные JSON в виде строки в теме, и я хотел бы использовать и обновить значение для...
Я работал над приложением, основанным на API-интерфейсе java kafka-streams, цель которого -...
У меня проблемы с использованием инструмента сброса приложений в Kafka Streams. Kafka streams...
Вариант использования: у меня есть приложение kafka streams, которое использует потребитель из...
Предположим, я хочу реализовать приложение, которое будет действовать как производитель и...
Когда вы создаете окно с использованием потоков kafka, я предполагаю, что оно использует метку...
У меня очень специфическое требование, когда я потребляю записи из темы Кафки. Записи, прочитанные...
Вопрос, связанный с обратной совместимостью Avro и локальными хранилищами RockSDB: Давайте...
У меня есть вопрос о сохранении журнала, и потоки Kafka Streams сокращают операции ... У меня есть...
У нас есть таблица kTable, в которой мы отображаем значения и материализуем их в KeyValueStore,...
У меня есть вопрос о Kafka Streams TopologyTestDriver (https://kafka.apache
У нас есть приложение для потоковой обработки, и в потоке мы извлекаем id и сохраняем его в...
Проект приложение, над которым я работаю, обрабатывает данные финансовых транзакций (ордеров и...
Предположим, у нас есть трансформатор (написанный на Scala) new Transformer[String, V, (String,...
У меня есть две темы со следующими данными: <ClientId, ClientConfiguration>...
Я использую Pipe.java, как указано в примере API потока https://kafka.apache
Я пишу приложение kafka-streams, которое в основном извлекает ключи 2 типов из записей avro и...
у нас есть KafkaAvroSerde, настроенный с несколькими URL-адресами для авторегистрации. В какой-то...
Я хочу знать разницу в повторном использовании потоков с помощью .through () по сравнению с...
Мы запускаем Kafka Streams с использованием контейнера AWS Fargate и получаем следующую ошибку при...
Скажем, например, у меня есть 4 раздела. Когда сообщение msg1 из ключ 101 помещается в раздел 1 (...
Так как rocksdb - постоянный магазин. Полезно ли хранить всю таблицу фактов в rocksdb, чтобы потоки...