У меня есть приложение RFID, которое получает постоянные сообщения датчиков в пределах области

У меня есть два объекта KTable: KTable<Long, byte[]> firstTable = builder

При использовании kafka-streams-scala, портирования lightbend kafka-streams-scala, в Scala 2.12 мы...

У меня есть тема с именем topic1 и тема с именем topic2 .У меня есть следующий код: - поток topic1...

У меня есть две уплотненные темы.Один содержит всю информацию о моем пользователе ( USERID ), а...

В моем приложении KStreams три экземпляра выполняются как развертывание в кластере kubernetes....

Мы создаем приложение kafka-streams как часть большой архитектуры микросервисов.Мы хотим быть...

У меня есть события, приходящие в Кафку.Требуется прочитать входящие данные и получить счетчики по...

Моя идея такова: Сначала groupByKey, затем ip, устройство уникально, затем map [ip, device] ip -...

У меня есть тема apache kafka "historyTopic", связанная с потоком: KStream<Long, byte[]>...

Я пытаюсь работать с потоками Кафки и создал следующую топологию: KStream<String,...

По умолчанию Kstream использует / tmp location для поддержания своего состояния (вида метаданных) с...

Мы столкнулись с проблемой из-за изменения API с Kafka 0.11 на Kafka 2.0.В нашем приложении потоков...

У меня проблема с моим приложением. Код: KTable<Long, byte[]> table = stream.groupByKey()

Я собираюсь создать потоковое приложение Kafka на основе Java, которое будет непрерывно слушать...

Я собираюсь рассчитать среднее с потоками кафки.Поэтому я делаю операцию с состоянием, агрегат,...

Я хочу создать приложение Kafka Streams, которое получает сообщения типа A.Для каждого ввода A...

Я получаю следующее исключение, когда пытаюсь создать экземпляр потоков kafka. Exception in thread...

Я знаю, что соединения могут быть выполнены с использованием API DSL.Нам нужно использовать...

Когда мне нужно загрузить тему без ключа как kTable, я обычно использую тему как kStream,...

У меня есть файл журнала темы и соответствующий файл .index.Я хотел бы читать сообщения в потоковом...

Например, потребление электроэнергии на одного клиента.Данные о потреблении не транслируются...

Это обобщение этого вопроса . Предположим, у меня есть несколько исходных потоков, для которых...

Я создаю материализованное представление из темы с помощью функции агрегирования из API весеннего...

KTable<Windowed<String>,Demo1> windowstream = dummy1 .groupByKey(Serialized