我有一个springboot消费者应用程序,使用springcloudstreamkafka连接到awsmsk。hvr充当生产者,以gzip压缩格式向主题生成数据。
现在在我的侦听器代码中,spring并没有自动解压缩kafka数据。从我读到的内容来看,消费者不需要明确提及任何解压缩代码。
在听这个主题的时候,我得到了以下例外:
Caused by: com.fasterxml.jackson.core.JsonParseException: Illegal character ((CTRL-CHAR, code 31)): only regular white space (\r, \n, \t) is allowed between tokens
at [Source: (byte[])
知道哪里出了问题。
暂无答案!
目前还没有任何答案,快来回答吧!