Kafka Streams API filter运算符报类型参数数量错误是什么原因

这个错误属于Java/Kotlin泛型参数不匹配的编码错误，常见触发场景如下：

• 声明KGroupedStream、KGroupedTable这类仅需要1个泛型参数（仅Key类型）的对象时，错误传入了2个泛型参数（同时写Key和Value类型）
• 调用count、reduce这类聚合算子时，返回值的泛型参数数量写错，这类聚合操作返回的KTable仅需要1个类型参数对应聚合结果的类型，不需要额外传Key类型参数
• 配置Serde、Consumed、Produced等配置类时，多传或者少传了泛型参数，比如单值序列化的场景下错误写了2个类型参数
• 自定义的Mapper、Predicate这类函数类的泛型参数数量和调用算子要求的数量不匹配

你可以先注释掉最近新增的流处理逻辑，逐段放开排查，定位到具体的报错代码行，检查对应API的泛型参数要求即可快速修复。

内容的提问来源于stack exchange，提问作者Stephen Chen