Насколько я понимаю, вы можете использовать методы process или transform для определения пользовательского поведения.
Я хочу передать каждое значение сообщения KStream в отдельный метод Java.Можно ли преобразовать значение сообщения KStream в String, которое я могу передать своему методу Java?
Я не могу найти ничего при преобразовании сообщения KStream в другой тип, поэтому яможет передать его методу.