apache-kafka - 如果超过特定的字节数，是否可以删除聚合（Kafka 流）？

Question

我的目标是将聚合设置null为超过一定数量的字节（序列化 json）。有什么方法还是保留时间是最终删除聚合的唯一方法？

标签： apache-kafkakafka-consumer-apiapache-kafka-streams

Answer 1

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

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