У меня есть различные источники данных, которые загружают обновления для одних и тех же записей в наш открытый API.Когда мы получаем обновление из любого источника,
Мы отправляем эту запись в TopicA,
Source1 -> {Update, "Time{14/06/2019 1:27:56}"}
Source2 -> {Update,"Time{14/06/2019 1:27:58}" }
, в данном случае
. Сначала мы можем получить обновление от Source1 из-зазадержка в сети от источника.Однако мы хотим решить эту проблему, используя Kafka Stream KTable.Разрешается ли этот сценарий с использованием KTable, KStream?