Spring Cloud Stream Kafka Streams - 如何在流中记录传入消息?

分类: 技术问答 • 2022-05-30 11:16:08

问题描述：

是否可以记录来自流函数的入站消息?是否有某种拦截器可以让我这样做?

Is it possible to log inbound messages from stream function? Is there some kind of interceptor that allows me to do that?

答

使用 KStream.peek(StreamLogger::in) 方法记录传入的字符串 :)

Log incoming string using KStream.peek(StreamLogger::in) methods :)