Я пытаюсь использовать пары Кафки, чтобы уменьшить последовательность чисел, и я хочу получить...
Я пытаюсь выяснить, как лучше распараллелить мои данные в отдельные заполнители для использования...
Я пытался посчитать событие из KStream в период времени: KStream<String, VehicleEventTO>...
Я строю микросервис весеннего облака, который использует данные из темы кафки.Что касается...
В нашем приложении мы стремимся брать сообщения JSON из входной темы, объединять их в заданном окне...