我无法升级我正在使用的Kafka broker (目前版本为0.10.0),而且有几条消息是由一个预-0.10.0生成程序编写的,所以我使用了一个自定义TimestampExtractor,在我的主类开始时将它作为默认配置添加到配置中但是在使用聚合操作符时,我遇到了一个异常,因为在使用内部聚合主题时,使用的是 TimestampExtractor 的实现而不是自定义实现。...Possibly because a pre-0.10 producer client was used to write