Я новичок в потоках kafka, и я пытаюсь объединить некоторые потоковые данные в KTable с помощью функции groupBy. Проблема в следующем: Созданное сообщение представляет собой сообщение json в следующем формате: { "current_ts": "2019-12-24...

Когда выполняются обновления основной темы GlobalKTable , какова логика для всех экземпляров KStream приложений для получения последних данных? Ниже приведены мои последующие вопросы: Будет ли GlobalKTable заблокирован на уровне записи или...

У меня есть этот метод, который вводит полезную нагрузку JSON. Я хочу создать K-таблицу из этой полезной нагрузки, прочитать из нее данные и распечатать ее. Пока что я должен создать KTable, но когда я перебираю его, элемент управления пропускает...