如果超过特定的字节数,是否可以删除聚合(Kafka 流)?



我的目标是在超过一定数量的字节(序列化 json)时将聚合设置为null。是否有某种方法,或者保留时间是最终删除聚合的唯一方法?

一般来说,这是可能的,但可能很昂贵。

如果Aggregator返回null,则相应的结果行将被删除。因此,每次调用Aggregator时,都可以在自己的代码中序列化结果,以检查其大小,如果结果太大,则返回null,否则返回新结果。不过,额外的序列化步骤可能很昂贵。

相关内容

  • 没有找到相关文章

最新更新