我在KStream中遇到方法不明确问题。
其实我不明白有什么不对。
.toStream()
.transformValues(
ValueTransformerWithKeySupplier<String, CandleDto, CandleDto> {
SuppressTransformer<String, CandleDto, CandleDto>(
Duration.ofMinutes(5),
"supress-store",
Duration.ofSeconds(5))
},
"suppress-store"
)这段代码的结果如下：
class SuppressTransformer<K, V, VR>(
private val windowSize: Duration,
private val storeName: String,
private val scheduleTime: Duration
) : ValueTransformerWithKey<K, V, VR> {
// Implementation
}
1条答案
按热度按时间nnsrf1az1#
更新：我刚刚意识到什么是错的（因为我是盲人）。谢谢@OneCricketeer，你的回答迫使我再次查看日志：-）
由于在转换前使用了窗口操作而导致错误并且必须在开始转换前Map值
现在它是可编译的：